Java 实现一个线程池
时间: 2023-07-17 15:07:56 浏览: 162
在Java中,可以使用`java.util.concurrent`包提供的`ExecutorService`接口来实现线程池。下面是一个简单的示例代码:
```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExample {
public static void main(String[] args) {
// 创建一个固定大小的线程池,大小为5
ExecutorService executor = Executors.newFixedThreadPool(5);
// 提交10个任务给线程池执行
for (int i = 0; i < 10; i++) {
Runnable task = new MyTask(i);
executor.execute(task);
}
// 关闭线程池
executor.shutdown();
}
static class MyTask implements Runnable {
private int taskId;
public MyTask(int taskId) {
this.taskId = taskId;
}
@Override
public void run() {
System.out.println("Task " + taskId + " is running.");
}
}
}
```
在上面的示例中,我们首先使用`Executors.newFixedThreadPool(5)`创建一个固定大小为5的线程池。然后,我们提交了10个任务给线程池执行,每个任务都是一个`MyTask`对象实现的`Runnable`接口。每个任务会打印出一个标识符来表示自己正在执行。
最后,我们调用`executor.shutdown()`关闭线程池。这会使得线程池停止接收新的任务,并且等待已经提交的任务执行完毕后关闭线程池。
阅读全文