我有一个具有以下两种方法的类。
public class Test1 {
public Mono<String> blah1() {
Mono<String> blah = Mono.just("blah1");
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("blah1 done");
return blah;
}
public Mono<String> blah2() {
Mono<String> blah = Mono.just("blah2");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("blah2 done");
return blah;
}
}
我有以下 JUnit:
@Test
public void blah1Test() {
Flux<Tuple2<String, String>> s = Flux.zip(test1.blah1(), test1.blah2());
}
我的结果如下:
blah1 done
blah2 done
我希望 blah2 在 blah1 之前完成。因此我相信这是处理阻塞而不是非阻塞。我需要做什么才能将输出切换到 blah2 然后 blah1 完成?基本上为什么这些不并行处理?
在此先感谢您的时间!