java如何等待某个事件而不是线程阻塞?
我正在为RapidMiner插件编写一个操作符。只要主方法doWork()
不返回,此运算符就处于活动状态。我的插件使用vert通过网络进行通信。x、 我有一个接收服务,它是有状态的,并处理接收到的消息。此服务与上述doWork()方法在同一线程(mainthread,唯一的线程)中运行。但是,由于操作符只是接收消息并处理它们,因此doWork()方法在设置对象后返回。相反,该方法应该在接收方服务接收到完成的事件后返回。所以我的问题是,如何在不阻塞线程的情况下等待这个事件,线程也会处理消息。目前,我试图使用ComblableFuture解决这个问题,但是get()
方法阻塞了线程,因此无法处理接收到的消息
共 (0) 个答案