Java中的线程池:如何避免资源浪费的实例
在Java中,线程池是一种管理和复用线程的方式。通过预创建一定数量的线程,当有新的任务需要执行时,只需要将任务放入队列,由线程池自动分配和处理,从而避免了频繁创建和销毁线程的资源浪费。
以下是一个简单的线程池实现例子(使用Java内置的ThreadPoolExecutor):
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);
// 提交任务到线程池
for (int i = 0; i < 10; i++) {
executor.submit(() -> {
System.out.println("Task " + i + " is running on thread " + Thread.currentThread().getId());
try {
Thread.sleep(1000); // 模拟耗时操作
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Task " + i + " completed on thread " + Thread.currentThread().getId());
});
}
// 关闭线程池,所有提交的任务会全部完成
executor.shutdown();
// 验证任务是否已经完成
while (!executor.isTerminated())) {
try {
Thread.sleep(1000); // 模拟检查频率
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("All tasks completed.");
}
}
这个例子中,线程池使用了ThreadPoolExecutor.newFixedThreadPool(5)
来创建,预设了5个线程。当有新的任务提交时,这些线程会去执行任务。任务完成后,线程会自动返回给线程池,等待下一次的任务分配。
还没有评论,来说两句吧...