如何問CompletableFuture使用非守護線程？

我已經寫了下面的代碼：如何問CompletableFuture使用非守護線程？

System.out.println("Main thread:" + Thread.currentThread().getId()); 
CompletableFuture<Void> future = CompletableFuture.runAsync(() -> { 
    try { 
     System.out.println("Before sleep thread:" + Thread.currentThread().getId(), + " isDaemon:" + Thread.currentThread().isDaemon()); 
      Thread.sleep(100); 
      System.out.println("After sleep"); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 
    }); 
    future.whenComplete((r, e) -> System.out.println("whenCompleted thread:" + Thread.currentThread().getId()));

而這一次打印：

Main thread:1 
Before sleep thread:11 isDaemon:true

和完成。

我該如何改變這種行爲？

P.S.我沒有看到任何東西runAsync Java文檔相關

來源

2017-09-04 gstackoverflow

@GhostCat，我只是在寫測試，這種行爲令我感到驚訝 – gstackoverflow

@GhostCat感謝您的查詢） – gstackoverflow

的javadoc爲runAsync()說：

返回一個新CompletableFuture是異步由ForkJoinPool.commonPool（運行任務完成）運行後給定的行動。

有另一版本的runAsync()在那裏你可以通一個ExecutorService。

這樣：當默認commonPool()不會做你想做的 - 然後創建自己的ExecutorService來代替。

來源

2017-09-04 08:25:59 GhostCat

添加這行：

ForkJoinPool.commonPool().awaitTermination(5, TimeUnit.SECONDS);

到main方法運行你的未來了。我會阻止，直到池中的所有任務都完成。

阻塞，直到所有任務在關閉請求後發生或發生超時，或者當前線程中斷（以先發生者爲準）完成執行。

來源

2017-09-04 08:57:02

after或before？ – gstackoverflow

後。我把它放在'main'方法的最後一行。 –

如何問CompletableFuture使用非守護線程？

回答

相關問題