意外的线程唤醒

Mar*_*rco 4 java multithreading notify wait spurious-wakeup

我期待以下示例中的第二个线程挂起,因为它等待没有相应通知的对象.相反,它落到了println,可能是由于虚假的唤醒.

public class Spurious {
    public static void main(String[] args) {

        Thread t1 = new Thread() { 
            public void run() { 
                System.out.println("Hey!"); 
            }  
        };
        Thread t2 = new Thread() { 
            public void run() 
            {
                try {
                    synchronized (t1) {
                        t1.wait();
                    }
                } catch (InterruptedException e) {
                    return;
                }
                System.out.println("Done.");
            }
        };
        t1.start();
        t2.start();
    }
}
Run Code Online (Sandbox Code Playgroud)

输出:

Hey!
Done.
Run Code Online (Sandbox Code Playgroud)

另一方面,如果删除"嘿!" println从第一个线程开始,第二个线程确实会挂起.这种情况发生在MacOS和Linux上.

知道为什么吗?

Nat*_*hes 6

这不是一个虚假的唤醒,一个虚假的唤醒是由JVM中的竞争条件引起的.这是您的代码中的竞争条件.

println使thread1保持忙碌的时间足够长,以至于thread2可以在thread1终止之前开始等待.一旦thread1终止,它就会向其监视器上等待的所有内容发送通知.thread2收到通知并停止等待.

删除println会减少thread1显着完成所需的时间,以便在thread2可以开始等待它时,thread1已经完成.thread1不再处于活动状态,并且在thread2开始等待之前已经发生了通知,因此thread2将永远等待.

Thread for join的API中记录了线程在死亡时发送通知:

此实现使用this.wait调用this.isAlive的循环.当一个线程终止时,将调用this.notifyAll方法.建议应用程序不要在Thread实例上使用wait,notify或notifyAll.

道德(嗯,道德之一)总是在一个带有条件变量的循环中等待,参见Oracle教程.如果您将Thread2更改为如下所示:

    Thread t2 = new Thread() { 
        public void run() 
        {
            try {
                synchronized (t1) {
                    while (t1.isAlive()) {
                        t1.wait();
                    }
                }
            } catch (InterruptedException e) {
                return;
            }
            System.out.println("Done.");
        }
    };
Run Code Online (Sandbox Code Playgroud)

然后thread2应该退出,无论thread2是否可以在thread1完成之前开始等待.

当然这是一个完整的玩具示例区域:

  • 不要扩展Thread.

  • 不要锁定线程.

  • 不要启动线程,使用Executors.

  • 更喜欢更高级别的并发结构来等待/通知.