Java創建線程池的代碼怎么寫

142次閱讀

共計 803 個字符，預計需要花費 3 分鐘才能閱讀完成。

Java 中創建線程池的代碼可以按照以下步驟進行：

導入相關的類和包：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

創建一個線程池對象：

ExecutorService executor = Executors.newFixedThreadPool(5);

這里使用 Executors.newFixedThreadPool() 方法創建一個固定大小的線程池，參數 5 表示線程池中的線程數量為 5。

定義一個實現 Runnable 接口的任務類：

class MyTask implements Runnable {public void run() {// 執行任務邏輯
    }
}

提交任務給線程池：

executor.submit(new MyTask());

這里使用 submit() 方法將任務提交給線程池進行執行。

關閉線程池：

executor.shutdown();

在任務執行完畢后，需要調用 shutdown() 方法關閉線程池。

完整的示例代碼如下所示：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

class MyTask implements Runnable {public void run() {// 執行任務邏輯
    }
}

public class ThreadPoolExample {public static void main(String[] args) {ExecutorService executor = Executors.newFixedThreadPool(5);
        for (int i = 0; i < 10; i++) {executor.submit(new MyTask());
        }
        executor.shutdown();}
}