Java进阶篇--Executors类创建常见线程池

目录

线程池架构 

newSingleThreadExecutor

newFixedThreadPool

newCachedThreadPool

newScheduledThreadPool

Executors和ThreaPoolExecutor创建线程池的区别

两种提交任务的方法

线程池架构 

线程池是一种线程管理的机制，用于维护和复用线程，以减少线程创建和销毁的开销。

在Java中，线程池的顶级接口是Executor，而真正的线程池接口是ExecutorService。以下是一些重要的类和接口：

  1. ExecutorService：真正的线程池接口，提供了执行、管理和控制任务的方法。

  2. ScheduledExecutorService：继承自ExecutorService，能够解决那些需要任务重复执行的问题，支持定时和周期性任务执行。

  3. ThreadPoolExecutor：ExecutorService的默认实现，提供了丰富的配置选项，如核心线程数、最大线程数、工作队列类型等。

  4. ScheduledThreadPoolExecutor：继承自ThreadPoolExecutor的ScheduledExecutorService接口实现，用于周期性任务调度。

要配置一个线程池是比较复杂的，尤其是对于线程池的原理不是很清楚的情况下，很有可能配置的线程池不是较优的，因此在Executors类里面提供了一些静态工厂，生成一些常用的线程池。

在Java中，可以通过Executors工厂类提供四种常见类型的线程池：

  1. newCachedThreadPool：创建一个可缓存线程池，适用于执行大量短期异步任务的场景，线程数量不受限制，可以灵活回收空闲线程。

  2. newFixedThreadPool：创建一个固定大小的线程池，适用于控制最大并发数的场景，超出的任务会在队列中等待。

  3. newScheduledThreadPool：创建一个定时线程池，用于支持定时及周期性任务执行的场景。

  4. newSingleThreadExecutor：创建一个单线程化的线程池，用于保证所有任务按照指定顺序执行的场景，只会使用唯一的工作线程来执行任务。

通过选择合适的线程池类型，并根据实际需求进行配置，可以有效管理和优化多线程任务的执行。

newSingleThreadExecutor

newSingleThreadExecutor 是 Executors 工厂类提供的一种线程池，它创建的是单线程化的线程池。具体来说，newSingleThreadExecutor 只会使用单个工作线程来执行任务，保证所有任务按照指定顺序（如 FIFO、LIFO、优先级）依次执行。

这种线程池适用于以下场景：

1. 顺序执行：需要按照特定顺序执行任务，避免并发引起的竞争条件或数据一致性问题。

2. 确保任务不被并发执行：有些任务可能不支持并发执行，此时可以使用单线程化的线程池来保证任务的顺序执行。

3. 上下文切换开销较大的任务：对于一些上下文切换开销较大的任务，如果采用并发执行可能带来额外的开销，可以选择单线程化的线程池来避免这种情况。

在单线程化的线程池中，任务会按照提交的顺序依次执行，不会存在并发执行的情况。如果某个任务由于异常结束，后续的任务会继续执行，不会受到影响。

以下是一个简单的 Java 代码示例，演示了如何使用 newSingleThreadExecutor 创建单线程化的线程池，并提交任务执行：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class main {public static void main(String[] args) {// 创建一个单线程化的线程池ExecutorService executor = Executors.newSingleThreadExecutor();// 提交多个任务给线程池执行for (int i = 0; i < 5; i++) {final int taskId = i;executor.submit(() -> {System.out.println("任务 " + taskId + " 正在线程上运行： " + Thread.currentThread().getName());try {Thread.sleep(1000); // 模拟任务执行} catch (InterruptedException e) {Thread.currentThread().interrupt(); // 保持中断状态}});}// 关闭线程池executor.shutdown();}
}

在上面的示例中，我们首先通过 Executors.newSingleThreadExecutor() 方法创建了一个单线程化的线程池。然后，使用 executor.submit() 方法向线程池提交了5个任务，每个任务都会打印当前线程名并模拟执行一段时间。最后，通过 executor.shutdown() 关闭了线程池。 

需要注意的是，虽然该线程池只使用单个工作线程来执行任务，但仍然可以通过 ExecutorService 提供的方法提交多个任务，这些任务会按照提交的顺序被放入队列，并由单个工作线程逐个执行。

总之，SingleThreadExecutor 用于串行执行任务的场景，每个任务必须按顺序执行，不需要并发执行。

newFixedThreadPool

newFixedThreadPool 是 Executors 工厂类提供的一种固定大小的线程池，它创建的线程池具有固定数量的工作线程。具体来说，newFixedThreadPool 创建的线程池会维护一个固定数量的工作线程，当有任务提交时，会使用其中一个工作线程来执行任务。

这种线程池适用于以下场景：

  1. 控制最大并发数：需要限制并发执行的任务数量，以防止系统资源被过度占用。

  2. 资源限制：对于一些资源受限的场景，如数据库连接池、网络连接池等，可以使用固定大小的线程池来控制资源的分配和利用。

  3. 预测性能需求：在已知任务量和性能需求的情况下，可以根据需求预先配置固定数量的工作线程，以保证系统在高负载时仍能稳定运行。

在固定大小的线程池中，线程的数量是固定的，不会根据任务的增加或减少而自动调整。如果所有工作线程都正在执行任务，并且有新任务提交时，新任务会被放入队列中等待，直到有工作线程空闲出来才会被执行。

以下是一个简单的 Java 代码示例，演示了如何使用 newFixedThreadPool 创建固定大小的线程池，并提交任务执行：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class main {public static void main(String[] args) {// 创建一个固定大小为3的线程池ExecutorService executor = Executors.newFixedThreadPool(3);// 提交多个任务给线程池执行for (int i = 0; i < 5; i++) {final int taskId = i;executor.submit(() -> {System.out.println("任务 " + taskId + " 正在线程上运行: " + Thread.currentThread().getName());try {Thread.sleep(1000); // 模拟任务执行} catch (InterruptedException e) {Thread.currentThread().interrupt(); // 保持中断状态}});}// 关闭线程池executor.shutdown();}
}

在上面的示例中，我们通过 Executors.newFixedThreadPool(3) 方法创建了一个固定大小为3的线程池。然后，使用 executor.submit() 方法向线程池提交了5个任务，每个任务都会打印当前线程名并模拟执行一段时间。最后，通过 executor.shutdown() 关闭了线程池。

当你运行这段代码时，你会看到虽然提交了5个任务，但是只有3个任务会同时在不同的工作线程中执行，因为线程池的大小被限制为3。剩余的任务会在有线程空闲时依次执行。

需要注意的是，在使用固定大小的线程池时，应该根据系统资源和运行环境合理地配置线程数量，避免资源浪费或不足的情况发生。

总之，FixedThreadPool 用于负载比较重的服务器，为了资源的合理利用，需要限制当前线程数量。

newCachedThreadPool

newCachedThreadPool 是 Executors 工厂类提供的一种可缓存线程池，它创建的线程池会根据需要自动调整线程数量。具体来说，当有新任务提交时，如果当前有空闲线程，则会立即使用空闲线程执行任务；如果没有空闲线程，则会创建新的线程来处理任务。而对于长时间闲置未被使用的线程，它们会在一定的空闲时间后被回收，从而使得线程池的大小能够动态调整。

这种线程池适用于以下场景：

  1. 处理大量短时耗任务：适用于有大量短时耗的任务需要处理的情况，例如网络请求响应、小数据处理等。

  2. 并发需求不确定：当并发需求不确定，且系统资源充足时，可以使用可缓存线程池来动态调整线程数量，以适应不同负载情况。

  3. 短期高并发：对于突发性的高并发情况，可缓存线程池能够快速创建新线程来应对，从而保证任务的及时处理。

以下是一个简单的 Java 代码示例，演示了如何使用 newCachedThreadPool 创建可缓存线程池，并提交任务执行：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class main {public static void main(String[] args) {// 创建一个可缓存线程池ExecutorService executor = Executors.newCachedThreadPool();// 提交多个任务给线程池执行for (int i = 0; i < 5; i++) {final int taskId = i;executor.submit(() -> {System.out.println("任务 " + taskId + "正在线程上运行： " + Thread.currentThread().getName());try {Thread.sleep(1000); // 模拟任务执行} catch (InterruptedException e) {Thread.currentThread().interrupt(); // 保持中断状态}});}// 关闭线程池executor.shutdown();}
}

在上面的示例中，我们通过 Executors.newCachedThreadPool() 方法创建了一个可缓存线程池。然后，使用 executor.submit() 方法向线程池提交了5个任务，每个任务都会打印当前线程名并模拟执行一段时间。最后，通过 executor.shutdown() 关闭了线程池。

当你运行这段代码时，你会看到所有5个任务都会立即在不同的工作线程中执行，因为可缓存线程池会根据需要动态调整线程数量。这种机制能够很好地适应不同负载情况下的任务处理需求。

需要注意的是，由于可缓存线程池的特性是动态调整线程数量，因此在任务提交过多导致线程数激增时，需要谨慎控制以避免资源耗尽的情况发生。

总之，CachedThreadPool 用于并发执行大量短期的小任务，或者是负载较轻的服务器。

newScheduledThreadPool

newScheduledThreadPool 是 Executors 工厂类提供的一种创建定时任务的线程池。它创建的线程池可以执行延迟任务和周期性任务，它会在给定的延迟时间后执行任务，或者定期执行任务。这种线程池适用于需要执行定时任务或者周期性任务的场景。

具体来说，newScheduledThreadPool 创建的线程池有以下特点：

  1. 支持延迟任务执行：可以使用 schedule() 方法提交一个任务，并指定延迟时间，线程池会在延迟时间过去后执行相应的任务。
  2. 支持周期性任务执行：可以使用 scheduleAtFixedRate() 或者 scheduleWithFixedDelay() 方法提交一个任务，并指定初始延迟时间和执行间隔，线程池会按照指定的间隔周期性执行任务。
  3. 灵活控制：可以通过 ScheduledExecutorService 提供的方法对定时任务进行取消、查询等操作，非常灵活方便。

在实际应用中，newScheduledThreadPool 可以用于定时数据同步、定时任务触发、定时器等场景，能够很好地满足对任务执行时间有特定要求的需求。

下面是一个简单的 Java 代码示例，演示了如何使用 newScheduledThreadPool 创建定时任务的线程池，并提交延迟任务和周期性任务：

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;public class main {public static void main(String[] args) {// 创建一个定时任务线程池ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);// 提交延迟任务executor.schedule(() -> System.out.println("延迟的任务"), 2, TimeUnit.SECONDS);// 提交周期性任务executor.scheduleAtFixedRate(() -> System.out.println("周期性任务"), 0, 1, TimeUnit.SECONDS);// 等待一段时间后关闭线程池try {Thread.sleep(5000);} catch (InterruptedException e) {Thread.currentThread().interrupt();}executor.shutdown();}
}

在上面的示例中，我们通过 Executors.newScheduledThreadPool(1) 方法创建了一个定时任务线程池。然后，使用 schedule() 方法提交了一个延迟任务，在2秒后执行；同时使用 scheduleAtFixedRate() 方法提交了一个周期性任务，每隔1秒执行一次。最后，我们等待一段时间后关闭了线程池。

当你运行这段代码时，你会看到延迟任务和周期性任务会按照预定的时间被执行。这展示了 newScheduledThreadPool 的定时任务执行能力。

总之，ScheduledThreadPoolExecutor 用于需要多个后台线程执行周期任务，同时需要限制线程数量的场景。

Executors和ThreaPoolExecutor创建线程池的区别

在 Java 中，确实存在着 Executors 工厂类的几种创建线程池的方法存在一些缺陷，让我们来具体分析一下。

1、newFixedThreadPool 和 newSingleThreadExecutor：

这两种方法都使用了无界的 LinkedBlockingQueue 作为工作队列，在任务提交速度持续大于任务处理速度的情况下，可能会导致队列中累积大量的任务，从而消耗大量内存。如果任务量非常大或者任务执行时间非常长，那么这种设计就会面临 OutOfMemoryError （简称：OOM）的风险。

2、newCachedThreadPool 和 newScheduledThreadPool：

这两种方法在某些情况下可能会创建大量的线程，因为它们的最大线程数是 Integer.MAX_VALUE。如果系统负载突然增加，那么就可能创建非常多的线程，从而消耗大量系统资源，甚至导致 OutOfMemoryError（简称：OOM）。

而相较之下，使用 ThreadPoolExecutor 构造函数创建线程池可以更好地控制线程池的行为，避免上述问题。通过 ThreadPoolExecutor 的构造函数，可以显式地指定核心线程数、最大线程数、工作队列类型、拒绝策略等参数，从而更精细地控制线程池的行为。

因此，在开发中，建议根据具体需求和系统负载情况，选择合适的线程池创建方法，并结合 ThreadPoolExecutor 来进行更为细致的参数配置，以避免潜在的问题。

两种提交任务的方法

ExecutorService 提供了两种提交任务的方法：

1、execute(Runnable command)：

这个方法用于提交不需要返回值的任务。它接受一个 Runnable 对象作为参数，表示要执行的任务，但并不关心任务的返回结果。

ExecutorService executor = Executors.newFixedThreadPool(10);
executor.execute(new RunnableTask());

2、submit(Callable<T> task)：

这个方法用于提交需要返回值的任务。它接受一个 Callable 对象作为参数，表示要执行的任务，并返回一个 Future 对象，通过它可以获取任务执行的结果。

ExecutorService executor = Executors.newFixedThreadPool(10);
Future<String> future = executor.submit(new CallableTask());
String result = future.get(); // 获取任务执行结果

通过这两种方法，可以灵活地提交不同类型的任务，并根据需要获取它们的执行结果。execute 方法适用于 fire-and-forget 的场景，而 submit 方法则更适合需要获取任务执行结果的情况。

以下是使用 ExecutorService 提供的 execute 和 submit 方法的示例代码：

import java.util.concurrent.*;public class main {public static void main(String[] args) throws InterruptedException, ExecutionException {// 创建一个固定大小为 3 的线程池ExecutorService executor = Executors.newFixedThreadPool(3);// 提交第一个任务Future<Integer> future1 = executor.submit(() -> {System.out.println("任务1正在运行");return 42;});// 提交第二个任务，并依赖于第一个任务的结果Future<Integer> future2 = executor.submit(() -> {int result = future1.get(); // 等待第一个任务的执行结果System.out.println("任务2正在根据任务1的结果运行： " + result);return result * 2;});// 提交第三个任务，并依赖于第二个任务的结果executor.execute(() -> {try {int result = future2.get(); // 等待第二个任务的执行结果System.out.println("任务3正在根据任务2的结果运行：" + result);} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}});// 关闭线程池executor.shutdown();}
}

在这个示例中，我们使用submit方法提交了第一个和第二个任务，并使用execute方法提交了第三个任务。第二个任务依赖于第一个任务的结果，而第三个任务则依赖于第二个任务的结果。通过这种方式，我们展示了如何在复杂情况下使用ExecutorService的execute和submit方法来提交具有相互依赖关系的任务。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/138548.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Leetcode2834. 找出美丽数组的最小和

Leetcode2834. 找出美丽数组的最小和

Every day a Leetcode 题目来源&#xff1a;2834. 找出美丽数组的最小和 解法1&#xff1a;贪心 从最小正整数 1 开始枚举&#xff0c;设当前数为 num&#xff0c;如果 nums 里没有 target - num&#xff0c;就说明可以添加 num&#xff0c;依次填满直到有 n 个数即可。 用…
阅读更多...
【k8s-1】基于docker Desktop一键式搭建k8s环境

【k8s-1】基于docker Desktop一键式搭建k8s环境

在docker desktop中一键启动k8s环境很简单。 下面介绍如何启动dashboard&#xff0c;dashboard仪表盘是新手学习k8s至关重要的一个工具。 1、配置控制台 kubectl apply -f https://raw.githubusercontent.com/kubernetes/dashboard/v2.5.1/aio/deploy/recommended.yaml 2、开…
阅读更多...
k8s的安装部署，详细过程展示（保姆级安装教程）

k8s的安装部署，详细过程展示（保姆级安装教程）

k8s应用部署方式演变 在部署应用程序的方式上&#xff0c;主要经历了三个时代&#xff1a; 传统部署&#xff1a;互联网早期&#xff0c;会直接将应用程序部署在物理机上 优点&#xff1a;简单&#xff0c;不需要其它技术的参与 缺点&#xff1a;不能为应用程序定义资源使用…
阅读更多...
Java面向对象（进阶）-- 面向对象特征之三：多态性

Java面向对象（进阶）-- 面向对象特征之三：多态性

文章目录 一、多态的形式和体现&#xff08;1&#xff09;为什么需要多态性(polymorphism)&#xff1f;&#xff08;2&#xff09; 对象的多态性 二、 多态的理解&#xff08;1&#xff09;如何理解多态性&#xff08;2&#xff09;Java中多态性的体现&#xff08;3&#xff09…
阅读更多...
数据分析实战 | KNN算法——病例自动诊断分析

数据分析实战 | KNN算法——病例自动诊断分析

目录 一、数据及分析对象 二、目的及分析任务 三、方法及工具 四、数据读入 五、数据理解 六、数据准备 七、模型训练 八、模型评价 九、模型调参 十、模型改进 十一、模型预测 一、数据及分析对象 CSV文件——“bc_data.csv” 数据集链接&#xff1a;https://dow…
阅读更多...
LeetCode146.LRU缓存

LeetCode146.LRU缓存

写了一个小时&#xff0c;终于把示例跑过了&#xff0c;没想到啊提交之后第19/22个测试用例没过 我把测试用例的输出复制在word上看看和我的有什么不同&#xff0c;没想到有18页的word&#xff0c;然后我一直检查终于找出了问题&#xff0c;而且这个bug真的太活该了&#xff0c…
阅读更多...
Rocky Linux 配置邮件发送

Rocky Linux 配置邮件发送

Rocky Linux 配置邮件发送 使用自己的有邮箱发送 第一步-开启STMP授权 首先要开启STMP授权码&#xff0c;以QQ邮箱为例 第二步-下载安装包 说明一点不用命令行安装也可以&#xff0c;在命令行中输入会提示你是否安装s-nail&#xff0c;一直y即可 mail下载必须要的安装包 …
阅读更多...
在ubuntu sudo apt-get update 更新报错

在ubuntu sudo apt-get update 更新报错

sudo apt-get update 更新报错 解决办法&#xff1a; 用你自己的key 根据上图自己找 sudo gpg --keyserver keyserver.ubuntu.com --recv-keys **********运行完成有一个ok 见下图 运行命令&#xff0c;中间的还是上面的key复制下来即可 sudo gpg --export --armor **********…
阅读更多...
Android 多点触控

Android 多点触控

三种类型 :接力型 /配合型 /单独型 单点触控 package com.example.myapplication.viewimport android.content.Context import android.graphics.Canvas import android.graphics.Paint import android.util.AttributeSet import android.view.MotionEvent import android.vi…
阅读更多...
10 # 手写 every 方法

10 # 手写 every 方法

every 使用 every() 方法测试一个数组内的所有元素是否都能通过指定函数的测试。它返回一个布尔值。 ele&#xff1a;表示数组中的每一个元素index&#xff1a;表示数据中元素的索引array&#xff1a;表示数组 <script>var arr [1, 3, 5, 7, 8];var result arr.ever…
阅读更多...
win 命令替代鼠标的操作

win 命令替代鼠标的操作

操作方式都是在 winR 输入框输入或者终端输入 1、快速打开 控制面板 运行control 2、快速打开 电源选项 运行powercfg.cpl 3、快速打开 网络连接 运行ncpa.cpl 4、快速打开 程序和功能 运行appwiz.cpl 5、快速打开 Windows Defender防火墙 运行Firewall.cpl 6、快速打开 鼠标 …
阅读更多...
Matlab的多项式留数与极点的计算

Matlab的多项式留数与极点的计算

Matlab的多项式留数与极点的计算 以下面的多项式为例&#xff1a; 运算代码&#xff1a; clc clear closesyms p % 定义多项式 Zp(5*p^571*p^370*p)/(2*p^635*p^4117*p^236); % 提取分子与分母 [I,D]numden(Zp); Idouble(coeffs(I,p,"All"));%分子 Ddouble(coeffs…
阅读更多...
多目标优化框架

多目标优化框架

随着模型越来越复杂&#xff0c;优化目标越来越多&#xff0c;传统算法都慢慢地无法胜任复杂优化任务&#xff0c;更为智能的优化方法也就应运而生了。其中有一类是进化优化算法&#xff0c;这类算法的思想来源是自然界的“优胜劣汰”法则&#xff0c;通过不停地保留好的个体最…
阅读更多...
大漠插件（二、Qt使用插件时注意事项）

大漠插件（二、Qt使用插件时注意事项）

本章目的 在上篇已经注册完毕大漠&#xff0c;那么怎么使用大漠来制作脚本&#xff0c;我选择了我最熟悉的Qt来开发&#xff0c;毕竟只是小软件&#xff0c;用脚本或者c都差不了多少。本章就是开发途中的一些坑。 本人开发环境是 win11 64、Qt 5.15.2安装了5.10.0的msvc2015 32…
阅读更多...
Linux - 基础IO（Linux 当中的文件，文件系统调用接口，文件描述符）- 上篇

Linux - 基础IO（Linux 当中的文件，文件系统调用接口，文件描述符）- 上篇

前言 首先&#xff0c;关于文件我们最先要理解的是&#xff0c;文件不仅仅存储的是数据&#xff0c;一个文件包括 内容 数据。内容好理解&#xff0c;就是我们先要这文件存储哪一些数据&#xff0c;这些数据就是文件的内容。 但是&#xff0c;在计算机当中&#xff0c;有两种…
阅读更多...
【数据结构】树与二叉树（十）：二叉树的先序遍历（非递归算法NPO）

【数据结构】树与二叉树（十）：二叉树的先序遍历（非递归算法NPO）

文章目录 5.2.1 二叉树二叉树性质引理5.1&#xff1a;二叉树中层数为i的结点至多有 2 i 2^i 2i个&#xff0c;其中 i ≥ 0 i \geq 0 i≥0。引理5.2&#xff1a;高度为k的二叉树中至多有 2 k 1 − 1 2^{k1}-1 2k1−1个结点&#xff0c;其中 k ≥ 0 k \geq 0 k≥0。引理5.3&…
阅读更多...
WAF入侵防御系统标准检查表

WAF入侵防御系统标准检查表

软件开发全文档获取&#xff1a;进主页
阅读更多...
GitHub Copilot Chat将于12月全面推出；DeepLearning.AI免费新课

GitHub Copilot Chat将于12月全面推出；DeepLearning.AI免费新课

&#x1f989; AI新闻 &#x1f680; GitHub Copilot Chat将于12月全面推出&#xff0c;提升开发者的生产力 摘要&#xff1a;GitHub宣布将于12月全面推出GitHub Copilot Chat&#xff0c;这是GitHub Copilot的一个新功能&#xff0c;旨在帮助开发者编写代码。它能够集成到开…
阅读更多...
【Linux】语言层面缓冲区的刷新问题以及简易模拟实现

【Linux】语言层面缓冲区的刷新问题以及简易模拟实现

文章目录 前言一、缓冲区刷新方法分类a.无缓冲--直接刷新b.行缓冲--不刷新&#xff0c;直到碰到\n才刷新c.全缓冲--缓冲区满了才刷新 二、 缓冲区的常见刷新问题1.问题2.刷新本质 三、模拟实现1.Mystdio.h2.Mystdio.c3.main.c 前言 我们接下来要谈论的是我们语言层面的缓冲区&…
阅读更多...
No source control providers registered

No source control providers registered

使用vscode时碰到这个问题 git扩展没启动
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023