如何解决如果在截止日期之前没有生产任何项目,则使用占位符项目完成 Uni,而不取消处理管道
我有一个需要很长时间才能完成的异步操作管道,我想 如果管道在截止日期之前没有生成项目,让 Uni 继续使用占位符项目,如下所示:
Uni<Item> u = processingPipeline();
return u.ifNoItem().after(Duration.of(10,SECONDS)).recoverWith(placeholderItem);
但是当使用这个方法时,处理管道被取消并且操作链被中断。 是否可以在截止日期到期时使用占位符项目完成 Uni 而不取消处理管道?即使错过了最后期限,我也希望管道能够持续到最后。 如果有帮助,可以使用 Vert.x。
谢谢
编辑:
这是我迄今为止尝试过的:
Uni<Item> u = processingPipeline();
return Uni.createFrom().emitter(emitter -> {
vertx.executeBlocking(handler -> {
u.subscribe().with(emitter::complete);
},resultHandler -> {});
vertx.setTimer(TimeUnit.SECONDS.toMillis(10),timerId -> {
emitter.complete(placeholderItem);
});
});
当处理在截止日期之前完成时,这可以正常工作,但是如果截止日期到期并且计时器被触发,它会在发出占位符项时与 javax.enterprise.context.ContextNotActiveException
崩溃,并且应用程序似乎陷入困境某种僵局。
编辑 2
事实证明,我的大部分问题实际上都是由于 Hibernate 使用不当造成的。在对 Hibernate 事务的管理方式进行一些重构后,所有随机死锁和其他问题都消失了。
这似乎是原始问题的最优雅的解决方案,即如何在不中断处理的情况下响应一个虚拟项目,除非它在截止日期之前完成:
Uni<Item> u = processingPipeline();
return Uni.createFrom().emitter(emitter -> {
u.subscribe().with(emitter::complete);
vertx.setTimer(TimeUnit.SECONDS.toMillis(10),timerId -> {
emitter.complete(placeholderItem);
});
});
解决方法
管道的取消是意料之中的,因为 ifNoItem().after(duration)
会触发 TimeoutException
。所以这个异常作为失败传播,并且在这个特定点的上游被取消,这符合响应式流语义。
recoverWith
是故障恢复操作符,以及订阅该操作符后的任何内容。
您可能需要查看 recoverWithUni
,您可以在其中提供 Uni
作为恢复,而 Uni
将捕获可能重新生成的管道的其余部分 -在这个特定的超时失败点之后订阅。
希望有所帮助。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。