如何在Netty中使用等待計時器？

Question

我有一個簡單的應用程序連接到服務器，發送一個ACK，然後發送一個文件進行處理。服務器發回一個ACK，然後發送處理輸入文件的結果，這可能在發送ACK之後幾秒發生。如果我沒有啓動計時器線程並在ACK之後繼續檢查響應文件是否進入，我的主線程退出。我希望接收套接字在明確關閉之前保持打開狀態。

如果有人能總結適用於在Netty中使用等待計時器的模式，我將不勝感激。

Answer 1

我會建議使用java.util.concurrent.CountDownLatch。初始化爲1（一），並將其傳遞給您的通道處理程序，並等待它在主線程中達到零。當處理程序收到最終結果時，會減少鎖存器。