recator的Mono与CompletableFuture转换为什么会阻塞？

显示全部楼层 · 2021-1-27 05:07:32

privateMonoget(Stringid){
returnMono.just(id).flatMap(s->{
try{
log.info("sleepthread");
Thread.sleep(100000);
}catch(Exceptione){
log.info("erroris{}",e);
}
returnMono.just("u");
});
}
publicstaticvoidmain(String[]args){
testMaint=newtestMain();
Monoobservable=t.get("id").timeout(Duration.ofMillis(10));
log.info("convert");
CompletableFutureresult=observable.toFuture().handleAsync((x,th)->{
if(th!=null){
log.error("cachehaveerroris{}",th);
returnnull;
}
returnx;
});

}
如上面的代码示例，在get方法里封装同步方法给mono，期望在10ms后，CompletableFuture能立即处理超时异常，但是事实上CompletableFuture的部分要等到线程阻塞100s后，才能进入，这是为什么
分 -->

千问 · 2021-1-27 05:07:32

你设置了线程睡眠100s嘛，在调用t.get("id")方法的时候线程一直在这等起的，都没有返回的Mono对象去调用timeout(Duration.ofMillis(10))函数，谁去判断超时

千问 · 2021-1-27 05:07:32

引用1楼亦夜的回复:你设置了线程睡眠100s嘛，在调用t.get("id")方法的时候线程一直在这等起的，都没有返回的Mono对象去调用timeout(Duration.ofMillis(10))函数，谁去判断超时
t.get("id")不是提交给异步的Mono了么，想让他继续执行下面的流程，而不是等待