【JDK中提供了哪些线程池】

简介: 【JDK中提供了哪些线程池】

理论

在JDK中,提供了四种线程池来管理线程,分别为:

  1. FixedThreadPool(固定大小线程池):该线程池的大小固定,不会随着任务数的增加而增加。当池子中的线程都在处理任务时,新的任务会处于等待状态,直到有线程可用。
  2. CachedThreadPool(缓存线程池):该线程池的大小不固定,可以根据需求自动调整线程池的大小。当池子中的线程都在处理任务时,新的任务会创建新的线程执行。
  3. SingleThreadExecutor(单一线程池):该线程池只有一个线程,确保所有任务都在同一线程中按顺序执行。所有提交给该线程的任务将按照先进先出(FIFO)的顺序执行。
  4. ScheduledThreadPool(定时器线程池):该线程池允许延迟或定时执行任务。它可以根据需要执行任务,并在任务执行完成后重新执行任务。

使用线程池的好处包括避免线程的频繁创建和销毁、线程的重用、线程的超时控制、任务队列的缓冲和限制等。根据任务的不同需求,可以选择不同类型的线程池来管理线程。

代码

以下是示例代码:

  1. FixedThreadPool:
ExecutorService executor = Executors.newFixedThreadPool(5); // 创建一个固定大小的线程池,大小为5
for (int i = 0; i < 10; i++) {
    executor.execute(new Runnable() { // 往线程池中提交10个任务
        @Override
        public void run() {
            System.out.println("Thread name: " + Thread.currentThread().getName()); // 输出当前线程的名称
            // do something
        }
    });
}
executor.shutdown(); // 关闭线程池
  1. CachedThreadPool:
ExecutorService executor = Executors.newCachedThreadPool(); // 创建一个缓存线程池
for (int i = 0; i < 10; i++) {
    executor.execute(new Runnable() { // 往线程池中提交10个任务
        @Override
        public void run() {
            System.out.println("Thread name: " + Thread.currentThread().getName()); // 输出当前线程的名称
            // do something
        }
    });
}
executor.shutdown(); // 关闭线程池
  1. SingleThreadExecutor:
ExecutorService executor = Executors.newSingleThreadExecutor(); // 创建一个单一线程池
for (int i = 0; i < 10; i++) {
    executor.execute(new Runnable() { // 往线程池中提交10个任务
        @Override
        public void run() {
            System.out.println("Thread name: " + Thread.currentThread().getName()); // 输出当前线程的名称
            // do something
        }
    });
}
executor.shutdown(); // 关闭线程池
  1. ScheduledThreadPool:
ScheduledExecutorService scheduledExecutor = Executors.newScheduledThreadPool(5); // 创建一个大小为5的定时器线程池
scheduledExecutor.schedule(new Runnable() { // 延迟1秒执行任务
    @Override
    public void run() {
        System.out.println("Task executed after 1 second.");
    }
}, 1, TimeUnit.SECONDS);
scheduledExecutor.scheduleAtFixedRate(new Runnable() { // 延迟1秒后开始执行任务,每隔2秒执行一次
    @Override
    public void run() {
        System.out.println("Task executed every 2 seconds.");
    }
}, 1, 2, TimeUnit.SECONDS);
scheduledExecutor.shutdown(); // 关闭线程池


相关文章
|
7月前
|
Java 调度 开发者
JDK 21中的虚拟线程:轻量级并发的新篇章
本文深入探讨了JDK 21中引入的虚拟线程(Virtual Threads)概念,分析了其背后的设计哲学,以及与传统线程模型的区别。文章还将讨论虚拟线程如何简化并发编程,提高资源利用率,并展示了一些使用虚拟线程进行开发的示例。
1132 4
|
7月前
|
缓存 安全 Java
JDK8线程池BUG引发的思考
JDK8线程池BUG引发的思考
172 0
|
7月前
|
存储 缓存 并行计算
【面试问题】JDK并发类库提供的线程池实现有哪些?
【1月更文挑战第27天】【面试问题】JDK并发类库提供的线程池实现有哪些?
|
算法 安全 Java
【Java】JDK 21中的虚拟线程以及其他新特性
【Java】JDK 21中的虚拟线程以及其他新特性
236 0
|
2月前
|
Dubbo Java 应用服务中间件
剖析Tomcat线程池与JDK线程池的区别和联系!
剖析Tomcat线程池与JDK线程池的区别和联系!
161 0
剖析Tomcat线程池与JDK线程池的区别和联系!
|
2月前
|
监控 数据可视化 Java
如何使用JDK自带的监控工具JConsole来监控线程池的内存使用情况?
如何使用JDK自带的监控工具JConsole来监控线程池的内存使用情况?
|
3月前
|
监控 数据可视化 Java
使用JDK自带的监控工具JConsole来监控线程池的内存使用情况
使用JDK自带的监控工具JConsole来监控线程池的内存使用情况
|
4月前
|
缓存 Java 调度
【Java 并发秘籍】线程池大作战:揭秘 JDK 中的线程池家族!
【8月更文挑战第24天】Java的并发库提供多种线程池以应对不同的多线程编程需求。本文通过实例介绍了四种主要线程池:固定大小线程池、可缓存线程池、单一线程线程池及定时任务线程池。固定大小线程池通过预设线程数管理任务队列;可缓存线程池能根据需要动态调整线程数量;单一线程线程池确保任务顺序执行;定时任务线程池支持周期性或延时任务调度。了解并正确选用这些线程池有助于提高程序效率和资源利用率。
66 2
|
4月前
|
算法 Java
JDK版本特性问题之想控制 G1 垃圾回收器的并行工作线程数量,如何解决
JDK版本特性问题之想控制 G1 垃圾回收器的并行工作线程数量,如何解决
|
6月前
|
存储 网络协议 Java
【JDK21】详解虚拟线程
【JDK21】详解虚拟线程
226 0