CompletableFuture 使用

?

?

@Testpublic void billiardTest() throws Exception { ? // 創(chuàng)建點(diǎn)外賣線程: ? CompletableFuture<Boolean> takeaway = CompletableFuture.supplyAsync(() -> { ? ? ? System.out.println("開始點(diǎn)外賣"); ? ? ? try { ? ? ? ? ? System.out.println("外賣 => 下單"); ? ? ? ? ? Thread.sleep(1000); ? ? ? ? ? System.out.println("外賣 => 店家接單開始做飯"); ? ? ? ? ? Thread.sleep(10000); ? ? ? ? ? System.out.println("外賣 => 做飯完成騎手接單"); ? ? ? ? ? Random random = new Random(); ? ? ? ? ? int time = random.nextInt(5); ? ? ? ? ? Thread.sleep(time * 1000); ? ? ? ? ? System.out.println("外賣 => 外賣已送達(dá)"); ? ? ? } catch (InterruptedException e) { ? ? ? ? ? e.printStackTrace(); ? ? ? } ? ? ? return true; ? }); ? //創(chuàng)建打球線程 ? CompletableFuture<Boolean> billiard = takeaway.supplyAsync(() -> { ? ? ? System.out.println("開始打桌球"); ? ? ? //直接用線程的返回值，不用中間變量，防止變量被篡改 ? ? ? while (!takeaway.getNow(false)) { ? ? ? ? ? try { ? ? ? ? ? ? ? System.out.println("打球 => 擺球"); ? ? ? ? ? ? ? Thread.sleep(1000); ? ? ? ? ? ? ? System.out.println("打球 => 打球"); ? ? ? ? ? ? ? Thread.sleep(5000); ? ? ? ? ? ? ? System.out.println("打球 => 打球結(jié)束確定輸贏"); ? ? ? ? ? } catch (InterruptedException e) { ? ? ? ? ? ? ? e.printStackTrace(); ? ? ? ? ? } ? ? ? } ? ? ? System.out.println("外賣已到，不再打球"); ? ? ? return true; ? }); ? //打球的結(jié)束，依賴外賣，所以這邊只需要看打球是否結(jié)束來(lái)確定是不是開始吃飯 ? billiard.thenAccept((param) -> { ? ? ? System.out.println("開始吃飯"); ? }); ? //主線程可以做其它事 ? while (true) { ? ? ? System.out.println("主線程可以做其它事：" + DateUtil.now()); ? ? ? Thread.sleep(1000); ? } }

鏈接：https://www.dianjilingqu.com/480782.html