如何在vert.x中执行长阻塞操作？

Question

Vext.x核心手册建议使用< code>executeBlocking()执行阻塞代码，以防止事件循环被阻塞。尽管如此，它还指出:

阻止代码 [在执行阻止] 应阻止合理的时间（即不超过几秒钟）。长阻塞操作...被排除在外。当阻止操作持续超过10秒时，将在控制台上打印一条消息[...]。长阻塞操作应使用由应用程序管理的专用线程，该线程可以使用事件总线或 runOnContext 与顶点进行交互

所以我不能在< code>executeBlocking中执行长阻塞操作。

为了说明这一点，例如，我正在阅读等待无限的数据流，例如按下键盘键。每次新数据到达（按下一个键）时，我都想将事件调度到事件总线。

while(keyboard.hasNextByte()) { // loops forever
  eventBus.publish("keyboard.keypress", keyboard.nextByte());
}

据我所知，创建自己的线程会破坏Vert.x的设计。那么，如何在不使用 executeBlocking 的情况下执行这种无限期阻塞代码呢？

Answer 1

我不认为创建“由应用程序管理”的单独线程的想法真的有问题。在您的情况下，这个线程非常简单，基本上，在应用程序启动时启动它，就这样。