Java中等待的最佳方式

Question

我有一个应用程序需要等待一段未知的时间。它必须等到服务器完成几个数据字段的填充。

服务器的 API 为我提供了一种请求数据的方法，非常简单...

服务器的 API 还提供了一种接收数据的方法，一次一个字段。它没有告诉我所有字段何时完成填充。

等待服务器完成处理我的请求的最有效方法是什么？这是一些伪代码：

public class ServerRequestMethods {
    public void requestData();
}

public interface ServerDeliveryMethods {
    public void receiveData(String field, int value);
}

public class MyApp extends ServerRequestMethods implements ServerDeliveryMethods {
    //store data fields and their respective values
    public Hashtable<String, Integer> myData;    

    //implement required ServerDeliveryMethods
    public void receiveData(String field, int value) {
        myData.put(field, value);    
    }

    public static void main(String[] args) {
        this.requestData();

        // Now I have to wait for all of the fields to be populated,
        // so that I can decide what to do next.

        decideWhatToDoNext();
        doIt();
    }
}

我必须等到服务器完成填充我的数据字段，并且服务器不会让我知道请求何时完成。所以我必须不断检查我的请求是否已完成处理。做到这一点最有效的方法是什么？

wait() 和notify()，有一个方法保护while 循环，每次我被notify() 唤醒时检查我是否拥有所有必需的值？

Observer 和 Observable，有一个方法可以在每次调用 Observer.Update() 时检查我是否拥有所有必需的值？

最好的方法是什么？谢谢。

Answer 1

很老的问题，但我寻找类似的问题并找到了解决方案。
首先，开发人员永远不应该创建一个永远等待的线程。如果您使用“while”循环，您确实必须创建“退出条件”。另外，等待“InterruptedException”也很棘手。如果另一个线程没有调用 yourThread.interrupt() 你将等到程序真正结束。
我使用了 java.util.concurrent.CountDownLatch，简而言之：

/*as field*/
CountDownLatch semaphore = new CountDownLatch(1);

/*waiting code*/
boolean timeout = !semaphore.await(10, TimeUnit.SECONDS);

/*releasing code*/
semaphore.countDown();

结果，“等待代码”线程将等待，直到另一个线程调用“释放代码”或“超时”。如果您想等待填充 10 个字段，请使用“new CountDownLatch(10)”。
这个原理与“java.util.concurrent.Semaphore”类似，但信号量更适合访问锁定，而这确实不是您的情况。

Answer 2

似乎很多人（包括我自己）都遇到了麻烦，但我找到了一个简单而时尚的解决方案。使用此方法：

public static void delay(int time) {
    long endTime = System.currentTimeMillis() + time;
    while (System.currentTimeMillis() < endTime) 
    {
        // do nothing
    }
}

获取当前时间并设置结束时间（当前时间 + 等待时间）并等待，直到当前时间达到结束时间。

Answer 3

如果我理解正确的话，其他一些线程会调用您的MyApp上的receiveData来填充数据。如果这是正确的，那么你可以这样做：

1. 你像这样睡觉：

   <前><代码>做{
   this.wait(someSmallTime); //我们正在获取“this”对象的监视器，因此需要通知。你应该花一些时间（比如 100 毫秒）来防止非常罕见但仍然可能发生的死锁，当通知在 this.wait 被调用之前到来时。
   while (!allFieldsAreFilled());

2. receiveData 应该进行 notify 调用，以unpause 的 wait 调用你的。例如这样：

   myData.put(字段，值);   
   this.notify();
   

3. 两个块都需要在 this 对象上“同步”，以便能够获取它的监视器（这是 wait 所需要的）。您需要将方法声明为“同步”，或者将相应的块放入 synchronized(this) {...} 块

Answer 4

使用 CompletionService

http://docs. oracle.com/javase/1.5.0/docs/api/java/util/concurrent/CompletionService.html

Answer 5

我认为最有效的方法是等待和通知。您可以使用 wait() 将线程设置为睡眠状态。您可以使用 notify() 从另一个线程（例如您的服务器）唤醒该线程。 wait() 是一种阻塞方法，您不必轮询任何内容。您还可以使用静态方法Thread.sleep(milliseconds)来等待一段时间。如果你把 sleep 放入一个无限的 while 循环中，检查一个持续等待时间的条件，你也会等待。

我更喜欢 wait() 和 notify()，它们效率最高。