要自定義并發線程池,可以使用ThreadPoolExecutor
類來實現。ThreadPoolExecutor
是ExecutorService
接口的一個實現類,可以用來創建和管理線程池。
以下是一個自定義并發線程池的示例:
import java.util.concurrent.*;
public class CustomThreadPool {
public static void main(String[] args) {
// 核心線程數
int corePoolSize = 2;
// 最大線程數
int maximumPoolSize = 5;
// 空閑線程存活時間
long keepAliveTime = 10;
// 時間單位
TimeUnit unit = TimeUnit.SECONDS;
// 工作隊列
BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(10);
// 創建自定義線程池
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(
corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
// 提交任務給線程池
for (int i = 0; i < 20; i++) {
threadPool.execute(new Task(i));
}
// 關閉線程池
threadPool.shutdown();
}
static class Task implements Runnable {
private int taskId;
public Task(int taskId) {
this.taskId = taskId;
}
@Override
public void run() {
System.out.println("Task " + taskId + " is running.");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
在上面的示例中,我們創建了一個ThreadPoolExecutor
線程池,設置了核心線程數為2,最大線程數為5,空閑線程存活時間為10秒。然后,我們使用execute()
方法提交了20個任務給線程池。每個任務是一個Task
對象,實現了Runnable
接口。在run()
方法中,我們打印了任務的id,并讓線程睡眠1秒。
最后,我們調用了shutdown()
方法來關閉線程池。