2 zfy1355 zfy1355 于 2016.03.04 18:33 提问

关于ReentrantLock使用的疑问?

直接上代码:

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();
            }
        }
     }

运行结果总会丢数字,难道是使用方法有问题?帮忙解答一下~

2个回答

u013596119
u013596119   Rxr 2016.03.04 22:20
已采纳

你在每个线程里都建立了不同的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();
            }
        }
     }
u013596119
u013596119 每个线程访问自己的对象就不存在synchronized的问题了
接近 2 年之前 回复
u013596119
u013596119 你new出来的是整个MulThreadTest,每个对象都有自己的a,a只是每个MulThreadTest实例的一个变量,我的代码里是只有一个对象,三个线程同时访问这一个对象的a,你的代码里是多个test,每个线程访问自己的test对象
接近 2 年之前 回复
zfy1355
zfy1355 a是静态变量,new出的每一个对象都是共享a对象的,所以不存在多个a对象的
接近 2 年之前 回复
wojiushiwo945you
wojiushiwo945you   Ds   Rxr 2016.03.05 13:25

锁同步是针对共享数据的,多线程对共享变量访问时,会涉及到数据竞争问题。
你的代码的问题是每个线程中都新new了一个MulThreadTest对象,单线程中访问各自的数据,就不存在互斥访问的问题了。
就好比每个人家都有WC,每个人访问的是自己家的WC,那么就不可能存在竞争等待问题。但是如果是公共区域,共享的WC,那么就需要锁同步了。

Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!