设计一个线程池且给出示例源代码
以下是一个简单的线程池的示例源代码:
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExample {
public static void main(String[] args) {
// 创建一个线程池,大小为4
ExecutorService executor = Executors.newFixedThreadPool(4);
// 提交任务给线程池
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 tasks");
}
}
class WorkerThread implements Runnable {
private String taskName;
public WorkerThread(String taskName) {
this.taskName = taskName;
}
public void run() {
System.out.println(Thread.currentThread().getName() + " Start. Task = " + taskName);
processTask();
System.out.println(Thread.currentThread().getName() + " End.");
}
private void processTask() {
try {
// 模拟任务处理时间
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
这个示例中,我们使用Executors.newFixedThreadPool()方法创建了一个线程池,大小为4。然后我们循环提交了10个任务给线程池,每个任务是一个实现了Runnable接口的WorkerThread对象。
WorkerThread对象的run()方法定义了任务的执行逻辑。在这个示例中,每个任务只是简单地打印一些信息,并通过processTask()方法模拟了一个耗时的任务处理过程。
最后,我们通过调用executor.shutdown()方法关闭线程池,并使用executor.isTerminated()方法等待所有任务完成
原文地址: https://www.cveoy.top/t/topic/iwzi 著作权归作者所有。请勿转载和采集!