等待更新

Question

等待事件/更新的最佳方式是什么？例如，我正在等待这个数据结构更新后再做某事。在循环内实现它并不是最好的方法，因为它会消耗大量的 CPU 时间，例如：

while (true) {
   // keep checking the data structure
   // if data structure is updated
   //    break;
}
// do something here

在 Java 中实现此类内容的简单但有效的方法是什么？

Answer 1

wait-notifyAll 是比循环更有效的方法。

wait() 的标准习惯用法：

synchronized (obj) {
    while(condition not hold) 
        obj.wait();
}

但它是控制线程的原始方法，您最好使用 java.util.concurrent 包中的类。而且，如果我遇到这样的问题，我会选择Chris Dail的答案。

Answer 2

这实际上取决于程序其余部分的结构。我可能会首先查看 java.lang. util.concurrent 看看里面的东西是否适合你。

实现此目的的方法示例：

• Futures - 如果您有一些“工作”要做，您可以使用线程池执行器服务来执行该工作。当您调用 submit() 时做你的工作，你就会得到一个你可以检查或阻止的未来，直到工作完成。

• 队列 - 如果您有一个组件执行工作，而一个组件执行等待，则可以通过队列完成它们的通信。每当人们处理完数据后，它就可以添加到队列中。您可以使用 LinkedBlockingQueue 和 poll() 来完成工作。

• 侦听器 - 根本没有并发，您可以使用侦听器/观察者模式。

根据您的应用程序结构，有许多不同的选项。

Answer 3

这是我要做的代码示例。

在此逻辑中，我在线程中使用 join 方法。这可确保在主线程继续执行之前所有线程都已加入。我已将 TODO 放在您需要添加代码的位置

import java.util.ArrayList;
import java.util.List;

public class MultiThread extends Thread{

    public void run() {
        System.out.println("Starting Thread - " + this.getName()+this.getThreadGroup());
        //TODO data structure is updated here
    }

    public static void main(String[] args) {
        List dataStructureList = new ArrayList() ;//TODO need to replace with list of data structure
        //TODO dataStructureList contain list of items
        Thread[] threadArr = new Thread[dataStructureList.size()];
        for (int j = 0; j < threadArr.length; j++) {
            threadArr[j] = new MultiThread();
            threadArr[j].setName("Thread " + j);
            threadArr[j].start();
        }
        try {
            for (int j = 0; j < threadArr.length; j++) {
                threadArr[j].join();
            }
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println("All thread finished");
        //TODO do something here

    }
}

Answer 4

假设您在应用程序中使用多线程。要将一个对象与多个线程一起使用，您应该使用同步。当一个线程初始化数据结构时，其他线程等待初始化完成。此逻辑通常使用可以在任何对象上调用的等待/通知方法来实现。

工作线程：

while (initialized) {
  synchronized (object) {
    object.wait();
  }
}

初始化线程：

synchronized (object) {
  // initialization
  initialized = true;
  object.notifyAll();
}

object 是需要初始化的数据结构。 initialized 标志用于指示初始化已完成。最好使用此标志，因为有时 wait 可能会在没有相应的 notify 的情况下完成。