问：JAVA当中的线程池，你知道哪些？

🕗 发布于 2024-09-19 09:05 java 开发语言

在多线程编程中，线程池是一种重要的设计模式，它允许我们重用现有的线程来执行任务，从而避免了频繁创建和销毁线程所带来的性能开销。Java的java.util.concurrent包提供了多种线程池实现，每种线程池都有其特定的用途和适用场景。本文针对四种常见的Java线程池：FixedThreadPool（固定大小线程池）、CachedThreadPool（缓存线程池）、SingleThreadExecutor（单线程线程池）和ScheduledThreadPool（定时线程池）进行说明。

一、FixedThreadPool（固定大小线程池）

FixedThreadPool是一种固定大小的线程池，它在初始化时指定了线程的数量，并且在整个生命周期中保持这个数量不变。当任务提交到线程池时，如果当前有空闲线程，则任务会立即执行；如果没有空闲线程，则任务会被放入等待队列中，等待有空闲线程时再执行。

示例代码：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class FixedThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executor = Executors.newFixedThreadPool(3);

        // 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            final int taskId = i;
            executor.submit(() -> {
                System.out.println("Task " + taskId + " is running by thread " + Thread.currentThread().getName());
                // 模拟任务处理
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            });
        }

        // 关闭线程池
        executor.shutdown();
    }
}

在上面的代码中，我们创建了一个固定大小为3的线程池，并提交了10个任务。由于线程池的大小是固定的，因此只有3个任务能够同时执行，其余的任务将等待空闲线程的出现。

二、CachedThreadPool（缓存线程池）

CachedThreadPool是一种可缓存的线程池，它没有固定的线程数量限制。当任务提交到线程池时，如果有空闲线程，则任务会立即执行；如果没有空闲线程，则线程池会创建一个新的线程来执行任务。当线程池中的线程在60秒内没有执行任务时，该线程将被终止并从池中移除。

示例代码：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class CachedThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个可缓存线程池
        ExecutorService executor = Executors.newCachedThreadPool();

        // 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            final int taskId = i;
            executor.submit(() -> {
                System.out.println("Task " + taskId + " is running by thread " + Thread.currentThread().getName());
                // 模拟任务处理
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            });
        }

        // 关闭线程池
        executor.shutdown();
    }
}

在上面的代码中，我们创建了一个可缓存的线程池，并提交了10个任务。由于线程池没有固定的线程数量限制，因此所有的任务都可以立即执行，而无需等待空闲线程的出现。

三、SingleThreadExecutor（单线程线程池）

SingleThreadExecutor是一种单线程的线程池，它保证所有的任务都按照提交的顺序执行。当任务提交到线程池时，如果当前有线程在执行任务，则新任务会被放入等待队列中，等待当前任务执行完毕后再执行。

示例代码：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class SingleThreadExecutorExample {
    public static void main(String[] args) {
        // 创建一个单线程化的线程池
        ExecutorService executor = Executors.newSingleThreadExecutor();

        // 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            final int taskId = i;
            executor.submit(() -> {
                System.out.println("Task " + taskId + " is running by thread " + Thread.currentThread().getName());
                // 模拟任务处理
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            });
        }

        // 关闭线程池
        executor.shutdown();
    }
}

在上面的代码中，我们创建了一个单线程的线程池，并提交了10个任务。由于线程池是单线程的，因此所有的任务都将按照提交的顺序依次执行。

四、ScheduledThreadPool（定时线程池）

ScheduledThreadPool是一种支持定时任务的线程池，它可以按照指定的时间间隔或延迟来执行任务。ScheduledThreadPool通常用于执行周期性任务或需要延迟执行的任务。

示例代码：

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个定时任务线程池
        ScheduledExecutorService executor = Executors.newScheduledThreadPool(3);

        // 提交定时任务到线程池
        executor.scheduleAtFixedRate(() -> {
            System.out.println("Task is executing by " + Thread.currentThread().getName());
        }, 0, 3, TimeUnit.SECONDS);

        // 注意：这里没有关闭线程池的代码，因为定时任务需要持续运行
        // 在实际应用中，你可能需要某种方式来优雅地关闭它
    }
}

在上面的代码中，我们创建了一个定时任务的线程池，并提交了一个每3秒执行一次的任务。由于定时任务需要持续运行，因此我们没有在代码中关闭线程池。

五、线程池对比

为了更直观地了解不同线程池的差异，以下是一个对比表格：

线程池名称	用途	适用场景	性能差异（简要说明）
FixedThreadPool	固定大小线程池	适用于并发量相对固定且任务执行时间较长的场景	性能稳定，资源利用效率高，但可能不适用于任务数量波动大的场景
CachedThreadPool	可缓存线程池	适用于执行大量短期异步任务的场景	能够快速响应任务请求，但可能会因为创建过多线程而消耗过多资源
SingleThreadExecutor	单线程线程池	适用于需要按顺序执行多个任务的场景	保证任务顺序执行，但并发处理能力有限
ScheduledThreadPool	定时线程池	适用于需要按照一定的时间间隔或延迟来执行任务的场景	支持定时和周期性任务，但并发处理能力取决于配置的线程数

性能差异详细说明：

FixedThreadPool：由于线程数量是固定的，因此性能相对稳定，不会因为任务数量的波动而产生较大的性能变化。同时，由于线程是复用的，因此资源利用效率较高。但是，当任务数量超过线程池的大小时，任务将被放入等待队列中，等待空闲线程的出现，这可能会导致任务的延迟执行。
CachedThreadPool：能够快速响应任务请求，因为当没有空闲线程时，线程池会立即创建一个新的线程来执行任务。但是，如果任务数量过多，线程池可能会创建大量的线程，从而导致资源的过度消耗和性能的下降。
SingleThreadExecutor：由于只有一个线程在执行任务，因此保证了任务的顺序执行。但是，这也限制了线程池的并发处理能力，当有大量任务需要同时执行时，可能会导致任务的延迟执行。
ScheduledThreadPool：支持定时和周期性任务，因此适用于需要按照一定时间间隔或延迟执行任务的场景。但是，由于线程池需要维护定时任务的状态和调度信息，因此可能会带来一定的性能开销。同时，并发处理能力也取决于配置的线程数。

六、结尾

本文解析了四种常见的Java线程池：FixedThreadPool、CachedThreadPool、SingleThreadExecutor和ScheduledThreadPool。说明每种线程池的用途、适用场景以及性能差异。在实际应用中，应根据具体的需求和场景选择最适合的线程池类型，以达到最佳的性能和资源利用效率。同时，也需要注意线程池的关闭和资源的释放，以避免资源的浪费和潜在的内存泄漏问题。

原文地址：https://blog.csdn.net/li_guolin/article/details/142348604

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：frida 命令参数作用
下一篇：QtConcorrent学习、以及与QThread之间的联系

Linux便捷查询使用手册第十二章：虚拟化与容器
虚拟化是指在单一硬件平台上运行多个虚拟计算机（虚拟机），每个虚拟机可以运行不同的操作系统和应用程序。虚拟化通过抽象物理硬件资源，使其能够在多个虚拟环境中共享。容器是轻量级的虚拟化技术，通过将应用及其依
阅读更多2024-11-16
Javaweb-day11案例（文件）
文件上传前端页面三要素1.在form表单中，要定义一个表单项，类型为file2.表单的提交方式必须得是POST方式下面是讲义里面的内容补充上传文件的原始form表单，要求表单必须具备以下三点（上传文件
阅读更多2024-11-16
深入理解 Linux top命令：用法详解与使用示例
linux topu命令界面各项介绍和一些组合命令介绍。
阅读更多2024-11-16
二叉树Golang
二叉树，深度优先搜索，广度优先搜索
阅读更多2024-11-16
Linux篇（权限管理命令）
在多用户计算机系统的管理中，权限是指某个特定的用户具有特定的系统资源使用权利在Linux 中分别有读、写、执行权限：权限针对文件权限针对目录读r表示可以查看文件内容；cat表示可以(ls)查看目录中存
阅读更多2024-11-16
【代码随想录day30】【C++复健】452. 用最少数量的箭引爆气球；435. 无重叠区间；763. 划分字母区间
而这也这是我想复杂的地方。
阅读更多2024-11-16
mysql存储过程模拟数据批量生成的函数模板
下面是个模板，需要自己。
阅读更多2024-11-16
使用 PyAnsys 在 Ansys 随机振动分析中检索螺栓连接中的力和应力
随机振动模拟通常用于评估组件承受运输过程中振动的能力。随机振动分析利用先前模态分析的频率和模式内容对通过功率谱密度 (PSD) 负载定义的频谱和功率内容进行线性叠加。在大多数装配模型中，螺栓连接（由求
阅读更多2024-11-16
C语言之MakeFile
定义: 变量名=变量值使用:取值;${变量名}或$(变量名)拼接:变量名+=值注意:1,makefile变量名可以以数字开头2,变量的大小是敏感的3,变量一般都在makefile的头部定义4,变量几乎
阅读更多2024-11-16
动态规划 —— 子数组系列-最大子数组和
53. 最大子数组和 - 力扣（LeetCode）
阅读更多2024-11-16

问：JAVA当中的线程池，你知道哪些 ？

一、FixedThreadPool（固定大小线程池）

二、CachedThreadPool（缓存线程池）

三、SingleThreadExecutor（单线程线程池）

四、ScheduledThreadPool（定时线程池）

五、线程池对比

六、结尾

相关文章

问：JAVA当中的线程池，你知道哪些？