java - 在非同步块中等待并通知

Question

抱歉我的格式不正确。我正在使用记事本编写程序。

这是一个有效的代码。我唯一的问题是，我已经读过必须在同步块中使用通知和等待。但是，在下面的示例中，在同步块中没有使用等待和通知，并且仍然没有抛出错误。

class counthrd implements Runnable {

    Thread thrd;
    String x;
    counthrd cnt1;

    counthrd() {
    }
    boolean suspended;
    boolean stopped;

    counthrd(String s, counthrd cnt1) {
        thrd = new Thread(this, s);
        this.cnt1 = cnt1;
        thrd.start();
        x = s;
    }

    public void run() {

        try {
            System.out.println("Starting " + thrd.currentThread().getName());
            for (int i = 1; i < 100; i++) {
                System.out.print(i + "  ");
                if ((i % 10) == 0) {
                    System.out.println();
                    Thread.sleep(500);
                }
//synchronized(cnt1){
                while (suspended) {
                    System.out.println("going to wait mode");
                    wait();
                    notify();
                }
//}
            }
        } catch (Exception e) {
            System.out.println(e);
        }
    }

    synchronized void suspendme() {
        suspended = true;
        notify();
    }

    synchronized void resumeme() {
        suspended = false;
        notify();
    }
}

class counter {

    public static void main(String args[]) throws InterruptedException {
        counthrd cnt1 = new counthrd();
        counthrd cnthrd1 = new counthrd("thrd 1", cnt1);

        Thread.sleep(1000);
        System.out.println("going to wait mode");
        cnt1.suspendme();
        Thread.sleep(1000);
        System.out.println("resuming");
        cnt1.resumeme();
        Thread.sleep(1000);
    }
}

Answer 1

见my comment。由于永远不会抛出 IllegalMonitorStateException，因此我们知道永远不会调用 wait。

请注意，您有两个 counthrd...

counthrd cnt1 = new counthrd();
counthrd cnthrd1 = new counthrd("thrd 1", cnt1);

查看您在哪个实例上调用suspendme 和resumeme？

Thread.sleep(1000);
System.out.println("going to wait mode");
cnt1.suspendme();
Thread.sleep(1000);
System.out.println("resuming");
cnt1.resumeme();
Thread.sleep(1000);

cnt1 使用您的无参数构造函数进行初始化，如下所示：

counthrd() {
}

关键是cnt1 从未真正启动它自己的线程。它从不做任何事情，真的。 cnthrd1 是启动线程的那个，如下所示：

counthrd(String s, counthrd cnt1) {
    thrd = new Thread(this, s);
    this.cnt1 = cnt1;
    thrd.start();
    x = s;
}

要说明的一点是suspended 是一个实例字段，而不是在cnt1 和cnthrd1 之间共享。修改cnt1.suspended 不会导致cnthrd1 进入“等待模式”。 wait 永远不会被调用，因此永远不会抛出异常。

为了演示，请尝试在cnthrd1 上调用suspendme 和resumeme，而不是... :-)

C:\dev\scrap>javac counter.java

C:\dev\scrap>java counter
Starting thrd 1
1  2  3  4  5  6  7  8  9  10
11  12  13  14  15  16  17  18  19  20
going to wait mode
going to wait mode
java.lang.IllegalMonitorStateException
resuming

---

话虽如此，我想我会建议你做一些你的代码应该做的事情。

1. 将suspended 声明为volatile。如果没有一些显式的内存排序保证，则无法保证cnthrd1 何时甚至如果 读取suspended 的更新值。
2. 放弃cnt1 字段和实例；他们没有理由。也摆脱那个空的构造函数。
3. Thread.currentThread 是静态方法；您不需要为此使用实例。除此之外，thrd 在这里保证等于 Thread.currentThread。
4. counthrd.x 等于 thrd.getName；为什么不直接使用x？
5. 使用更好、更具描述性的名称。例如，为什么不用x 而不是name？为什么不用thrd 而不是thread？为什么不用counthrd 而不是CountingThread？
6. 您只需要在resumeme 中调用notify，而不是suspendme。 （事实上​​，在suspendme 中调用notify 可能会在线程处于休眠状态时意外触发InterruptedException，即当(i % 10) == 0 时）
7. 您也不希望notify 在while (suspended) 循环中。现在，您的 while 循环实际上也可以转换为 if 语句。
8. 如前所述，您需要在调用 while 的代码周围使用 synchronized (this)。
9. 避免在构造函数中执行真正的逻辑，例如thrd.start()。
10. suspend 不需要是 synchronized。 resume 也不需要是 synchronized；只有wait 和notify 调用需要它。

您可以找到可以正常工作的示例的修改版本here。