ExecutorService 创建一个单线程的线程池
时间: 2024-07-02 11:00:27 浏览: 168
ExecutorService 是Java并发编程中的一个重要工具,它提供了一种管理线程执行任务的方式。如果你想创建一个单线程的线程池,你可以使用 `newSingleThreadExecutor()` 方法。这个方法创建的是一个固定大小的线程池,其中只有一个工作线程,当提交的任务到达时,这个线程会立即执行。
以下是如何使用 `ExecutorService` 创建单线程线程池的一个简单示例:
```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class SingleThreadThreadPoolExample {
public static void main(String[] args) {
// 创建单线程线程池
ExecutorService executor = Executors.newSingleThreadExecutor();
// 提交任务
for (int i = 0; i < 10; i++) {
Runnable worker = new WorkerThread("" + i);
executor.execute(worker); // 任务将立即执行,因为线程池只有一条线程
}
// 关闭线程池
executor.shutdown();
while (!executor.isTerminated()) {
// 等待所有任务完成
}
System.out.println("All threads completed.");
}
}
class WorkerThread implements Runnable {
private String command;
public WorkerThread(String command) {
this.command = command;
}
@Override
public void run() {
System.out.println("Worker Thread " + command + " is running.");
// 在这里添加你要执行的代码
}
}
```
在这个例子中,`WorkerThread` 类的实例被提交到线程池中执行,由于线程池只有一个线程,所以这些任务会依次执行,而不是同时运行。
阅读全文