Future详解( 八 ) _生活百科

5）任务交互
1.介绍：所谓线程交互，是指将两个线程任务获取结果的速度相比较，按一定的规则进行下一步处理。
2.方法列举：
【1】applyToEither
1.说明
//两个线程任务相比较，先获得执行结果的，就对该结果进行下一步的转化操作。public <U> CompletionStage<U> applyToEither(CompletionStage<? extends T> other,Function<? super T, U> fn);public <U> CompletionStage<U> applyToEitherAsync(CompletionStage<? extends T> other,Function<? super T, U> fn);2.示例
CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(new Supplier<Integer>() {@Overridepublic Integer get() {int number = new Random().nextInt(10);System.out.println("第一阶段start：" + number);try {TimeUnit.SECONDS.sleep(number);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第一阶段end：" + number);return number;}});CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(new Supplier<Integer>() {@Overridepublic Integer get() {int number = new Random().nextInt(10);System.out.println("第二阶段start：" + number);try {TimeUnit.SECONDS.sleep(number);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第二阶段end：" + number);return number;}});future1.applyToEither(future2, new Function<Integer, Integer>() {@Overridepublic Integer apply(Integer number) {System.out.println("最快结果：" + number);return number * 2;}});【2】acceptEither
1.说明
//两个线程任务相比较，先获得执行结果的，就对该结果进行下一步的消费操作。public CompletionStage<Void> acceptEither(CompletionStage<? extends T> other,Consumer<? super T> action);public CompletionStage<Void> acceptEitherAsync(CompletionStage<? extends T> other,Consumer<? super T> action);2.示例
CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(new Supplier<Integer>() {@Overridepublic Integer get() {int number = new Random().nextInt(10) + 1;try {TimeUnit.SECONDS.sleep(number);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第一阶段：" + number);return number;}});CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(new Supplier<Integer>() {@Overridepublic Integer get() {int number = new Random().nextInt(10) + 1;try {TimeUnit.SECONDS.sleep(number);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第二阶段：" + number);return number;}});future1.acceptEither(future2, new Consumer<Integer>() {@Overridepublic void accept(Integer number) {System.out.println("最快结果：" + number);}});【3】runAfterEither
1.说明
//两个线程任务相比较，有任何一个执行完成，就进行下一步操作，不关心运行结果。public CompletionStage<Void> runAfterEither(CompletionStage<?> other,Runnable action);public CompletionStage<Void> runAfterEitherAsync(CompletionStage<?> other,Runnable action);2.示例
CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(new Supplier<Integer>() {@Overridepublic Integer get() {int number = new Random().nextInt(5);try {TimeUnit.SECONDS.sleep(number);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第一阶段：" + number);return number;}});CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(new Supplier<Integer>() {@Overridepublic Integer get() {int number = new Random().nextInt(5);try {TimeUnit.SECONDS.sleep(number);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第二阶段：" + number);return number;}});future1.runAfterEither(future2, new Runnable() {@Overridepublic void run() {System.out.println("已经有一个任务完成了");}}).join();【4】runAfterBoth
1.说明
//两个线程任务相比较，两个全部执行完成，才进行下一步操作，不关心运行结果。public CompletionStage<Void> runAfterBoth(CompletionStage<?> other,Runnable action);public CompletionStage<Void> runAfterBothAsync(CompletionStage<?> other,Runnable action);

Future详解( 八 )

经验总结扩展阅读

鲈鱼蒸多久就可以熟了鲈鱼蒸多长时间可以熟

菠萝蜜的功效及禁忌

白墙上的胶带留下印怎么去除

福泉市的特色景点有哪些?

炒花蛤怎么做

一月份适合去哪里旅游旅游景点告诉你

财运线杂乱的手相好不好

什么东西好吃健康不胖

抑郁症患者抑郁症：若想走向康复与强大，你必须学会与自己的灵魂对话

出汗对痘印有改善吗对人体有哪些好处

水培铜钱草分盆分株的方法

温州|行拘＋退学处理！温州高校深夜通报两起男生骚扰女性事件处理进展

moss时尚圈过年了！来“蹦迪”的明星们用了什么？

2023年1月9日安装门户好吗 2023年1月9日是安装门户的黄道吉日吗

2022年农历腊月初七开学典礼吉日 2022年12月29日适合开学典礼吗

擦眼镜怎么擦才正确

vivoT1和荣耀50哪个好_vivoT1和荣耀50参数对比

宝宝咳嗽吃什么好得快

许三观卖血记|活着是生命的力量，活得好是人生的态度

罗兰会算命吗_啥八字的女人易被抛弃