为什么以下非常简单的代码不能工作。卡住了..。我正在尝试使用显式锁java.util.concurrent.locks.ReentrantLock;及其newCondition()方法。
这是我的代码:
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;
public class TheCondition implements Runnable {
ReentrantLock lock = new ReentrantLock();
Condition condition = lock.newCondition();
static int variable = 2;
public void incrementVariable() throws InterruptedException
{
lock.lock();
try{
condition.await();
for (int i = 0;i<100000;i++){
variable++;
}
}
finally
{
lock.unlock();
}
}
public static void main (String []args) throws InterruptedException
{
TheCondition tc = new TheCondition();
Thread t1 = new Thread(tc);
t1.start();
Thread.sleep(1000);
tc.incrementVariable();
t1.join();
System.out.println(variable);
}
public void run()
{
for (int i = 0;i<100000;i++){
variable++;
}
System.out.println(variable);
lock.lock();
try{
condition.signalAll();
}
finally{
lock.unlock();
}
}
}我把锁锁在同一个锁上,所以应该能用.相反,当它调用incrementVariable()时,它会在主线程中被阻塞。为什么会发生这样的事?提前谢谢。
发布于 2013-07-23 16:17:19
首先执行run,它在几微秒内完成。当没有线程对信号执行signalAll时,此方法将调用await。然后,再过一秒钟,在主线程中调用incrementVariable,这自然会挂在await方法上,永远不会接收到信号。
https://stackoverflow.com/questions/17815381
复制相似问题