Java 并发编程:Java 线程池的介绍与使用
warning:
这篇文章距离上次修改已过180天,其中的内容可能已经有所变动。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExample {
public static void main(String[] args) {
// 创建固定大小的线程池
ExecutorService executorService = Executors.newFixedThreadPool(5);
// 提交任务到线程池执行
for (int i = 0; i < 10; i++) {
executorService.execute(new RunnableTask());
}
// 关闭线程池,以优雅的方式
executorService.shutdown();
}
}
class RunnableTask implements Runnable {
@Override
public void run() {
System.out.println("Task executed on thread: " + Thread.currentThread().getName());
}
}
这段代码创建了一个固定大小的线程池,并提交了多个任务(RunnableTask实例)来执行。通过线程池执行任务,可以有效管理线程的创建和销毁,提高程序的性能。最后,使用shutdown()
方法优雅地关闭线程池,以防止中断还在执行的任务。
评论已关闭