java - ReentrantLock 不起作用

标签 java concurrency reentrantlock

我不明白为什么代码不能正常工作。问题是 ReentrantLock 没有锁定 ThreadClass.run() 中的方法调用

Resource-class哪些方法被假定为在ThreadClass中被锁定

public class ResourceClass {

    private int i; 

    public void setIncrement() {
        i++;
    }

    public int getIncrement() {
        return i;
    }

}

线程类

public class ThreadClass implements Runnable {

    private ResourceClass resource;
    private ReentrantLock reentrantLock = new ReentrantLock();

    ThreadClass(ResourceClass r) {
        resource = r;
    }

    public void run() {
        reentrantLock.lock();
        try {
            resource.setIncrement();
            System.out.println(resource.getIncrement());
        } finally {
            reentrantLock.unlock();
        }
    }

}

主类

public class MainClass {

    public static void main(String[] args) {

        ResourceClass resource = new ResourceClass();

        Thread thread = new Thread(new ThreadClass(resource));
        thread.start();
        Thread thread2 = new Thread(new ThreadClass(resource));
        thread2.start();
        Thread thread3 = new Thread(new ThreadClass(resource));
        thread3.start();
    }

} 

假设 run() 中被锁包围的代码必须是“同步的”,因此只有一个线程可以访问资源对象的方法。在实践中它没有。代码结果重复数字,这意味着两个线程可以同时访问这些方法。我知道这是一个非常简单的问题,但我不明白如何解决它。感谢您的帮助。

更新:

我明白了。那段代码工作得很好(我删除了 setIncrement() 并将所有相关逻辑放入 getIncrement() 中):

public int getIncrement() {
        reentrantLock.lock();
        int incrementResult = i++;
        reentrantLock.unlock();
        return incrementResult;
} 

最佳答案

您正在为每个可运行对象创建一个新的 ReentrantLock,这意味着没有同步。您需要与每个 Runnable 实例共享一把锁。

关于java - ReentrantLock 不起作用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29259240/

相关文章:

java - 如何在 Java 应用程序的底部创建一个栏,例如状态栏?

java - JPA一对多关系查询

c# - 如何使用 ForNpgsqlUseXminAsConcurrencyToken 创建的 EF Core 并发 token

java - 如果 ReentrantLock 已锁定,则等待但不锁定该锁

java - 对求偶数斐波那契数之和的运行时间感到困惑

java - 将类实现接口(interface)传递给另一个实现相同接口(interface)的构造函数?

java - Guava Striped 的正确条纹数是多少?

java - 如何在 Infinispan 中使用 JTA 事务?

java - SharedArray 死锁和引发条件

java - 检查是否持有锁,如果空闲则不锁