程序暂停：wait() 和 notify()

Question

我正在努力实现这一点：创建了两个不同的线程，一个打印奇数，一个打印偶数。一旦一个线程打印了一个数字，它就必须等待另一个线程等等，一个接一个。

为了实现这一点，我将同步块与 wait() 和 notify() 一起使用。

我正在创建一个 class 其对象将用于传递给两个线程中的同步块。

代码如下：

--> 这是将传递给同步块的已用对象。

package com.vipin.multithread.variousdemos;

    public class SyncObject {

        public SyncObject () {  

        }
}

奇数线程：

package com.vipin.multithread.variousdemos;

public class OddThread implements Runnable {

private Thread t;
int index=0;
SyncObject so=null;

int odd_nums[] = {1,3,5,7,9};

public OddThread(SyncObject so) {
    t = new Thread(this,"Odd Thread");
    this.so = so;
    t.start();
}

public Thread getThreadInstance() {
    return t;
}

@Override
public void run() {
    while (true) {
        synchronized(so) {
            System.out.println("Odd num is --->" + odd_nums[index]);
            try {
                so.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            index++;
            so.notify();
            if(index>=5) {
                return;
            }
        }
    }
}
}

偶线程：更新

package com.vipin.multithread.variousdemos;

public class EvenThread implements Runnable {

private Thread t;
int index=0;
SyncObject so=null;

int even_nums[] = {2,4,6,8,10};

public EvenThread(SyncObject so) {
    t = new Thread(this, "Even thread");
    this.so = so;
    t.start();
}

public Thread getThreadInstance() {
    return t;
}

@Override
public void run() {
    while(true) {   
        synchronized(so) {
            System.out.println("Even num is --->" + even_nums[index]);
            so.notify(); <-- Here we are notifying.
            try {
                so.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            index++;
            //so.notify(); <-- commented out.
            if(index>=5) {
                break;
            }
        }
    }
}
}

主要应用：

package com.vipin.multithread.variousdemos;

public class EvenOddDemo {

public static void main(String[] args) throws InterruptedException {
    SyncObject so = new SyncObject();

    OddThread ot = new OddThread(so);
    EvenThread et = new EvenThread(so);

    System.out.println("\nIn main thread");

    Thread.sleep(1000000000);

    System.out.println("Exiting main thread...");
}
}

---> 如代码所示，我正在创建两个线程来打印偶数和奇数。我正在使用同步块，并传递 ==> SyncObject 类型的对象。

我将 SyncObject 作为参数传递给 main 中的这些不同线程。

但是，这个程序会停止，即只执行第一个语句，然后永远等待：

这是输出：

奇数是--->1

在主线程中偶数是 --->2

我无法理解为什么这个程序永远等待，我正在使用我们正在调用 synchronized()、wait() 和 notify() 的 SAME 对象。按照我的理解，应该可以，不知道为什么不行。

关于为什么要永远等待的任何线索。

更新：

我对代码做了一些修改，UPDATE，它工作正常。

我还有点疑惑。 notify() 是否被线程调用，即使它没有锁定监视器，就像我更新代码后的情况一样。

事件顺序：

首先执行奇数线程，然后调用 wait() <-- 它释放监视器，现在处于睡眠模式。

甚至线程运行，打印消息，并调用 notify() <-- 在这里我没有清楚地理解。

Even线程调用notify()时，此时它有monitor，那么当它调用notify()时，是否仍然拥有monitor？

现在，在偶数线程调用notify()之后，奇数线程得到通知，因此它从休眠点开始执行。它正在执行一些操作并调用 notify()，此时我认为奇数线程不拥有监视器，它调用 notify()。所以，我的问题是，无论线程是否拥有监视器，notify() 的工作是否相同？

只有自己写代码的时候才真正明白这一点。我看了书，觉得我什么都懂了，看来我又回到原点了！

Answer 1

这里的问题很简单，就是两个线程都直接进入了等待状态。线程 1 获取 so，打印值然后等待。线程 2 然后获取 so，打印值然后等待。所以他们都在睡觉，因为没有人在那里通知他们。因此，一个简单的解决方法是在 so.wait() 之前执行 so.notify()。那么他们就不会无限期地等待。

编辑

奇数线程启动、执行然后等待。然后甚至线程启动、执行、通知并等待。 Even thread 持有监视器上的锁，直到它进入等待状态。

当偶数线程调用notify时，奇数线程唤醒并轮询锁。一旦偶数线程进入等待状态（&释放锁），那么奇数线程就可以获得锁。

如果偶数线程没有调用notify，那么奇数线程会继续休眠。偶数线程会去等待并释放锁。没有线程正在轮询或尝试获取锁，因此程序保持挂起状态。

documentation也提供了类似的解释。我希望这能消除你的疑虑。

程序暂停：wait() 和 notify()

Program gets halted: wait() and notify()

java

multithreading

synchronized

notify

wait

代码如下：

奇数线程：

偶线程：更新

主要应用：

这是输出：

更新：