直接上代码:
import java.util.concurrent.locks.ReentrantLock;
public class MulThreadTest {
public static int a = 0;
ReentrantLock lock = new ReentrantLock(true);
public void addInt(){
lock.lock();
a++;
System.out.println(Thread.currentThread().getName()+"___________"+a +"_ " + lock.getHoldCount());
lock.unlock();
}
public static void main(String[] args) throws InterruptedException {
for(int i=0;i<3;i++){
new Thread(new Runnable() {
@Override
public void run() {
MulThreadTest test = new MulThreadTest();
for(int j=0;j<100;j++)
test.addInt();
}
},"thread"+i).start();
}
}
}
运行结果总会丢数字,难道是使用方法有问题?帮忙解答一下~
你在每个线程里都建立了不同的text,也就是有三个不同的a在三个不同的test的实例里,这样改就可以了,三个线程访问的是同一个test实例,addInt也是针对同一个a,这样输出就可以看出lock的作用了
import java.util.concurrent.locks.ReentrantLock;
public class MulThreadTest {
public static int a = 0;
ReentrantLock lock = new ReentrantLock(true);
public void addInt(){
lock.lock();
a++;
System.out.println(Thread.currentThread().getName()+"___________"+a +"_ " + lock.getHoldCount());
lock.unlock();
}
public static void main(String[] args) throws InterruptedException {
final MulThreadTest test = new MulThreadTest();
for(int i=0;i<3;i++){
new Thread(new Runnable() {
@Override
public void run() {
for(int j=0;j<100;j++)
test.addInt();
}
},"thread"+i).start();
}
}
}
锁同步是针对共享数据的,多线程对共享变量访问时,会涉及到数据竞争问题。
你的代码的问题是每个线程中都新new了一个MulThreadTest对象,单线程中访问各自的数据,就不存在互斥访问的问题了。
就好比每个人家都有WC,每个人访问的是自己家的WC,那么就不可能存在竞争等待问题。但是如果是公共区域,共享的WC,那么就需要锁同步了。