threadpoolexecutor实现
时间: 2023-08-14 07:41:56 浏览: 79
threadPool的实现代码
ThreadPoolExecutor是Java中的一个线程池实现,可以帮助我们管理线程池中的线程,从而优化程序的性能。下面是一个简单的ThreadPoolExecutor的实现示例:
```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
public class ThreadPoolExecutorDemo {
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);
executor.execute(worker);
}
// 关闭线程池
executor.shutdown();
while (!executor.isTerminated()) {
}
System.out.println("Finished all threads");
}
}
class WorkerThread implements Runnable {
private String taskName;
public WorkerThread(String taskName) {
this.taskName = taskName;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + " executing " + taskName);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
```
在这个示例中,我们使用了Executors工厂类创建了一个ThreadPoolExecutor,该线程池包含5个线程。我们使用一个for循环将10个任务提交到线程池中,并且在每个任务执行时都会输出线程名和任务名。最后,我们调用shutdown()方法关闭线程池,并且通过isTerminated()方法判断线程池中的所有线程是否都已经执行完毕。
阅读全文