java異步調用 如何管理線程池

在Java中，可以使用ExecutorService和CompletableFuture來管理和優化線程池。下面是一些關于如何使用這些工具的建議：

1. 使用ExecutorService創建線程池：

   ExecutorService是一個用于執行和管理線程的接口。你可以使用Executors類提供的工廠方法來創建不同類型的線程池，例如固定大小的線程池、緩存線程池等。

   int numberOfThreads = 10;
   ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads);
   

2. 提交任務到線程池：

   使用ExecutorService的submit()方法將任務提交到線程池。這個方法接受一個實現了Runnable或Callable接口的對象，并返回一個表示異步計算結果的Future對象。

   Runnable task = () -> {
       // Your task code here
   };
   
   Future<?> future = executorService.submit(task);
   

3. 使用CompletableFuture管理異步任務：

   CompletableFuture是一個實現了Future和CompletionStage接口的類，它提供了一種簡潔的方法來處理異步編程。你可以使用CompletableFuture.supplyAsync()方法創建一個異步任務，并使用thenApply(), thenAccept(), thenRun()等方法處理任務結果。

   CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
       // Your task code here
       return "Task result";
   }, executorService);
   
   future.thenApply(result -> {
       // Process the task result
       return result.toUpperCase();
   }).thenAccept(result -> {
       // Print the task result
       System.out.println("Task result: " + result);
   });
   

4. 關閉線程池：

   當所有任務都完成后，應該關閉線程池以釋放資源。你可以使用shutdown()方法來關閉線程池，這將阻止新任務的提交，但仍然允許已提交的任務繼續執行。如果需要立即關閉線程池并停止所有正在執行的任務，可以使用shutdownNow()方法。

   executorService.shutdown();
   try {
       if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
           executorService.shutdownNow();
       }
   } catch (InterruptedException e) {
       executorService.shutdownNow();
   }
   

通過使用ExecutorService和CompletableFuture，你可以更有效地管理和優化Java中的線程池，從而提高應用程序的性能和響應能力。