ReentrantLock 不起作用
ReentrantLock doesn't work out
我不明白为什么代码不能正常工作。问题是 ReentrantLock 没有锁定 ThreadClass.run()
中的方法调用
Resource-class ThreadClass
假定哪些方法被锁定
public class ResourceClass {
private int i;
public void setIncrement() {
i++;
}
public int getIncrement() {
return i;
}
}
线程-class
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();
}
}
}
主-class
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();
}
}
假设运行()中被lock包围的代码一定是"synchronised",结果只有一个线程可以访问Resourse-object的方法。在实践中它没有。代码结果重复数字,这意味着两个线程可以同时访问这些方法。我知道这是一个非常简单的问题,但我不明白如何解决它。感谢您的帮助。
更新:
我明白了。那段代码工作得很好(我删除了 setIncrement() 并将所有相关逻辑放入 getIncrement() ):
public int getIncrement() {
reentrantLock.lock();
int incrementResult = i++;
reentrantLock.unlock();
return incrementResult;
}
您正在为每个可运行对象创建一个新的 ReentrantLock
,这意味着没有同步。您将需要与每个 Runnable 实例共享一把锁。
所以你的意思是在 Thread
class 中有一个静态的 ReentrantLock
。
我不明白为什么代码不能正常工作。问题是 ReentrantLock 没有锁定 ThreadClass.run()
中的方法调用Resource-class ThreadClass
假定哪些方法被锁定public class ResourceClass {
private int i;
public void setIncrement() {
i++;
}
public int getIncrement() {
return i;
}
}
线程-class
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();
}
}
}
主-class
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();
}
}
假设运行()中被lock包围的代码一定是"synchronised",结果只有一个线程可以访问Resourse-object的方法。在实践中它没有。代码结果重复数字,这意味着两个线程可以同时访问这些方法。我知道这是一个非常简单的问题,但我不明白如何解决它。感谢您的帮助。
更新:
我明白了。那段代码工作得很好(我删除了 setIncrement() 并将所有相关逻辑放入 getIncrement() ):
public int getIncrement() {
reentrantLock.lock();
int incrementResult = i++;
reentrantLock.unlock();
return incrementResult;
}
您正在为每个可运行对象创建一个新的 ReentrantLock
,这意味着没有同步。您将需要与每个 Runnable 实例共享一把锁。
所以你的意思是在 Thread
class 中有一个静态的 ReentrantLock
。