java实现手动创建线程池
时间: 2023-07-17 08:01:14 浏览: 140
要在Java中手动创建线程池,您可以使用`java.util.concurrent.Executors`类提供的`ThreadPoolExecutor`类。以下是一个示例:
```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Main {
public static void main(String[] args) {
// 创建一个线程池,其中包含5个线程
ExecutorService executor = Executors.newFixedThreadPool(5);
// 提交任务给线程池
for (int i = 0; i < 10; i++) {
Runnable worker = new WorkerThread("Task " + (i + 1));
executor.execute(worker);
}
// 关闭线程池
executor.shutdown();
while (!executor.isTerminated()) {
// 等待所有任务完成
}
System.out.println("所有任务已完成");
}
}
class WorkerThread implements Runnable {
private String taskName;
public WorkerThread(String taskName) {
this.taskName = taskName;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + " 开始执行任务: " + taskName);
// 执行任务的逻辑代码
System.out.println(Thread.currentThread().getName() + " 完成任务: " + taskName);
}
}
```
在上面的示例中,我们使用`Executors.newFixedThreadPool()`方法创建了一个固定大小为5的线程池。然后,我们提交了10个任务给线程池,并且每个任务都由一个`WorkerThread`实例表示。最后,我们调用了`shutdown()`方法来关闭线程池,并使用`isTerminated()`方法等待所有任务完成。
阅读全文