java - 等待和通知的代码执行顺序

Question

我研究使用 wait 和 notify 方法进行同步。

我写了一个小例子，不明白为什么我会看到这个输出:

take 1
release 1
release 2

我的代码:

主要内容:

public class CustomSemaphoreTest {
    public static void main(String[] args) throws InterruptedException {

        Semaphore semaphore = new Semaphore();
        SendingThread sender = new SendingThread(semaphore);
        RecevingThread receiver = new RecevingThread(semaphore);
        sender.start();
        Thread.sleep(300);
        receiver.start();

    }
}

发件人:

class SendingThread extends Thread {
    volatile Semaphore semaphore = null;
    int count = 1;

    public SendingThread(Semaphore semaphore) {
        this.semaphore = semaphore;
    }

    public void run() {
        this.semaphore.take();
    }
}

接收者:

class RecevingThread extends Thread {
    volatile Semaphore semaphore = null;
    int count = 1;

    public RecevingThread(Semaphore semaphore) {
        this.semaphore = semaphore;
    }

    public void run() {
        while (true) {
            try {
                this.semaphore.release();
                Thread.sleep(20);
            } catch (InterruptedException e) {
            }
            // System.out.println("get signal " + count++);
        }
    }
}

信号量:

class Semaphore {
    private boolean signal = false;
    int rCount = 1;
    int sCount = 1;

    public synchronized void take() {
        System.out.println("take " + sCount++);
        this.signal = true;
        this.notify();
        try {
            wait();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    public synchronized void release() throws InterruptedException {
        System.out.println("release " + rCount++);
        notify();
        while (!this.signal) {
            wait();
        }
        this.signal = false;
    }
}

我是如何想象这个程序的执行的？:

时间 0:线程 1:sender.start() ->...->

public synchronized void take() {
        System.out.println("take " + sCount++);
        this.signal = true;
        this.notify(); //try wake up waiting threads but noone sleep thus have not affect
        try {
            wait(); // release monitor and await notify
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

因此我在屏幕上看到 take 1

时间 300:线程 2 receiver.start(); ->

 public synchronized void release() throws InterruptedException {
        System.out.println("release " + rCount++);  //section is rid thus this lines outputes
        notify(); // notify thread1
        while (!this.signal) {
            wait(); // pass the control to thread1 and await notification .....
        }
        this.signal = false;
    }

因此我没想到会看到release 2

请澄清我的误解。

Answer 1

您在 wait() 之后设置 signal = false。

事件的顺序。

1. sender 调用 take()
2. sender 打印
3. signal 设置为 true
4. receiver 收到通知
5. sender 调用 wait()
6. receiver 唤醒
7. receiver 打印
8. 发件人 收到通知
9. signal 是 true 所以没有 wait()
10. signal 设置为 false
11. release() 方法结束
12. receiver 循环
13. receiver 打印
14. signal 是 false 所以 wait()
15. sender 唤醒并立即退出，无事可做

所以你有几个问题

1. 您的发件人不循环
2. 您在错误的时间设置了信号