您几乎应该总是将谓词与等待/通知一起使用。也就是说,您需要可以检查的条件,例如变量变为true,队列变为空/满等。仅盲目地等待某人调用.notify()的用例很少。
因此,以下内容并不正确,由于您所说的原因,另一个线程可以在ThreadA调用.wait()之前调用.notify()。
public class ThreadA { public static Object latch = new Object(); public static void main(String[] args) { ThreadB b = new ThreadB(); b.start(); synchronized(latch ) { latch.wait(); //wait for B to finish a calculation } System.out.println("Total is: " + b.total); }}class ThreadB extends Thread { int total; @Override public void run() { for (int i = 0; i < 100; i++) { total += i; } synchronized(ThreadA.latch) {ThreadA.latch.notify(); } }}
您需要执行以下 *** 作:
public class ThreadA { public static Object latch = new Object(); public static boolean done = false; public static void main(String[] args) { ThreadB b = new ThreadB(); b.start(); synchronized(latch ) { while (!done) { //wait for B to indicate it is finished. latch.wait(); } } System.out.println("Total is: " + b.total); }}class ThreadB extends Thread { int total; @Override public void run() { for (int i = 0; i < 100; i++) { total += i; } synchronized(ThreadA.latch) {ThreadA.done = true; ThreadA.latch.notify(); } }}
请注意,在上面,该
done变量受同步块保护,
.wait()将自动释放/重新获取该锁。因此,没有竞争条件,如果在进行调用之前
.wait()调用了.notify(),则ThreadA会发现原因
done是,因为将存在
true且根本没有进入该
.wait()调用。
对于这种代码这样的简单情况,您可以等待ThreadB结束,可以通过
b.join();
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)