Java中創建線程池的代碼可以按照以下步驟進行:
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
ExecutorService executor = Executors.newFixedThreadPool(5);
這里使用Executors.newFixedThreadPool()
方法創建一個固定大小的線程池,參數5表示線程池中的線程數量為5。
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();
}
}