多线程新手——如何在java中使用wait()和notify()？

Question

我正在尝试编写一个包含 2 个类的程序，一个控制器和一个执行大量计算的类。控制器创建另一个类的几个实例，然后告诉它们全部开始计算（并行）。它们各自在完成后返回，控制器恢复，然后，一段时间后，控制器向它们传递新数据，并让它们再次运行计算。
理想情况下，我可以使用参数调用 start() ，但这是不可能的，因此控制器调用计算器中的一个方法，将数据存储在全局中，然后启动计算线程并返回，直到我尝试再次启动线程，它告诉我线程已死。因此，我试图使运行成为一个无限循环，只等待直到收到通知，运行计算，将结果存储在全局中，以便控制器稍后可以检索它们，然后恢复等待。所以像这样：

//in controller:
Calculator calc=new Calculator();
calc.runCalculations(data);
while(calc.isCalculating()){
    //do nothing
}
System.out.println("results: "+calc.getAnswer());
calc.runCalculations(data2);

//in calculator:
public runCalculations(Data data){
    globalData=data;
    this.notify();
}
public void run(){
    while(true){
        synchronized(this){
            wait();
        }
        calculating=true;
        globalData=calculate(globalData);
        calculating=false;
    }
}

Answer 1

在调用 notify() 之前，您需要获取 this 上的监视器。
另外，当您调用 wait() 时，您应该在一个循环中执行此操作，以检查条件以确保您没有遇到虚假唤醒。

public runCalculations(Data data){
    globalData=data;
    synchronized(this) {
        calculating=true;
        this.notify();
    }
}
public void run(){
    while(true){
        synchronized(this){
            calculating=false;
            while(!calculating) {
                wait();
            }
        }
        globalData=calculate(globalData);
    }
}

一般来说，大多数人会建议不要使用等待/通知，而是建议您使用 Executor 或至少使用 BlockingQueue。但这两者都需要你重新设计你目前的想法。