java-如何不斷等待事件發生

Question

我正在創建一個應用程序，其中有多個階段 - 每個階段的消息發送到我的隊列中的亞馬遜簡單工作流程（SWF）...應用程序應該爲每條收到的消息啓動一個新的線程。

如何實現等待部分 - 以便應用程序不斷掃描隊列中的新消息並在收到消息時採取行動？

Answer 1

您可以執行的一種方法是pollqueue，直到您在while loop機制中收到新消息爲止。只要您收到新消息，就可以調用自己的操作。

Answer 2

使用一個ServerSocket：

serversocket

特別

的。接受（）方法等待有人需要連接。然後你可以實例化一個新的線程，傳遞需要的參數來保持連接（地址，端口等）。

Answer 3

你問被稱爲生產者 - 消費者模式什麼 你可以讀到它here

的基本思想是：該網站是一個製片人，你是作爲一個客戶端消費者。

你等待（），直到聽衆收到一條消息，然後notifAll（）

class WaitForAmazon{ 
    private boolean available = false; 
    private int contents; 

    public synchronized int consumer() { 
     while (available == false) { 
      try { 
       wait(); 
      } catch (InterruptedException e) { } 
     } 
     available = false; 
     notifyAll(); 
     return contents; 
    } 

    public synchronized void producer(int value) { 
     while (available == true) { 
      try { 
       wait(); 
      } catch (InterruptedException e) { } 
     } 
     contents = value; 
     available = true; 
     notifyAll(); 
    } 
} 

Answer 4

BlockingQueue及其實施LinkedBlockingQueue可以在這裏很有用。

當Thread將通過調用

queue.take() 

和隊列將是空想從隊列take的東西，這樣的線程將等待，直到其他線程調用

queue.put(something). 

也把東西放到隊列如果隊列已滿，則queue.put()將使線程等待，直到新元素的隊列中將有空間。