netty - 如何在 Netty 中使用等待计时器？

Question

我有一个简单的应用程序，它连接到服务器，发送 ACK，然后发送要处理的文件。服务器发回一个 ACK​​，然后发送处理输入文件的结果，这可能在发送 ACK 几秒钟后发生。如果我不启动计时器线程并在 ACK 之后继续检查响应文件是否已进入，我的主线程将退出。我本来希望接收套接字保持打开状态，直到明确关闭。

如果有人可以总结适用于在 Netty 中使用等待计时器的模式，我将不胜感激。

Answer 1

我建议使用 java.util.concurrent.CountDownLatch。初始化为 1（一），并将其传递给您的通道处理程序，并等待它在主线程中达到零。当处理程序收到最终结果时，它会减少锁存器。