executor线程池框架_如何使用Java 5 Executor框架创建线程池

executor线程池框架

Java 5以Executor框架的形式在Java中引入了线程池,它允许Java程序员将任务提交与任务执行分离。 如果要使用Java进行服务器端编程,则线程池是维护系统可伸缩性,鲁棒性和稳定性的重要概念。 对于那些不熟悉Java中的线程池或这里的线程池的概念的人来说,Java中的线程池是工作线程的池,它可以执行提供给他们的任何任务,主要是通过Runnable的实现形式或Callable接口。 由于Java本身支持编程语言中的多线程,因此它允许多个线程同时运行并执行任务的并行处理。 在本文中,我们将学习有关Java线程池的以下内容:

  1. Java中的线程池是什么?
  2. 为什么我们需要Java中的线程池?
  3. Java 5中的Executor框架是什么?
  4. 如何使用Java中的Executor框架创建固定大小的线程池?
  5. 在Java中使用线程池的好处?

什么是Java中的线程池以及我们为什么需要它

JavaSparrow-med
正如我所说的,线程池是已经创建好的工作线程池,准备好执行此工作。 线程池是任何多线程服务器端Java应用程序都需要的基本功能之一。 使用线程池的一个示例是创建一个Web服务器,该服务器处理客户端请求。 如果您熟悉套接字编程,那么您将知道ServerSocket.accept()会阻塞方法,并在建立套接字连接之前一直阻塞 。 如果仅使用一个线程来处理客户端请求,则它将随后限制可以同时访问服务器的客户端数量。 为了支持大量客户端,您可以决定每个请求范例使用一个线程,其中每个请求由单独的线程处理,但这要求在请求到达时创建线程。 由于创建线程是耗时的过程,因此会延迟请求处理。 它还根据每个JVM允许的线程数限制客户端的数量,这显然是有限的。 线程池为您解决了这个问题,它创建了线程并进行管理。 线程池不是以创建线程并在完成任务后将其丢弃的方式,而是以工作线程的形式重用线程。 由于线程通常是在应用程序启动时创建并池化的,因此您的服务器可以立即开始请求处理,这可以进一步缩短服务器的响应时间。 除此之外,在Java应用程序中使用线程池还有其他好处,我们将在下一部分中看到。 简而言之,我们需要线程池来更好地管理线程并将任务提交与执行分离。 Java 5中引入的线程池和Executor框架是库提供的出色线程池。

Java线程池– Java 5中的执行器框架

Java 5引入了一些有用的功能(例如Enum , 泛型 , 变量参数)以及多个并发集合和实用程序(例如ConcurrentHashMap和BlockingQueue等),还引入了完整功能的内置线程池框架(通常称为Executor框架) 。 该线程池框架的核心是Executor接口,该接口使用方法execute(Runnable task)定义任务执行的抽象; ExecutorService扩展了Executor以添加各种生命周期和线程池管理工具,例如关闭线程池。 Executor框架还提供了一个称为Executors的静态实用程序类 (类似于Collections), 该类提供了几种静态工厂方法来创建Java中各种类型的线程池实现,例如固定大小的线程池,缓存的线程池和计划的线程池。

Runnable和Callable接口用于表示由这些线程池中管理的工作线程执行的任务。 Executor框架的有趣之处在于,它基于Producer使用者设计模式 ,其中应用程序线程产生任务和worker线程使用者或执行那些任务,因此,它也遭受了Producer使用者任务的限制,例如生产速度大大高于消耗速度当然,仅当您的队列不受限制时,您才可能因为排队的任务而运行OutOfMemory。

如何使用Java中的Executor框架创建固定大小的线程池?

由于Executors类提供了静态工厂方法,因此使用Java 5 Executor框架创建固定大小的线程池非常容易。 您需要做的就是定义要同时执行的任务,然后将该任务提交给ExecutorService。 通过它们,线程池将负责如何执行该任务,该线程可以由任何空闲的工作线程执行,并且如果您对结果感兴趣,则可以查询Submit()方法返回的Future对象。 Executor框架还提供了不同类型的线程池,例如SingleThreadExecutor仅创建一个工作线程,或者CachedThreadPool在需要时创建工作线程。 您还可以查看Executor框架的Java文档以获取此API提供的服务的完整详细信息。 实践中的Java并发性还有两章专门介绍如何有效使用Java 5 Executor框架,对于任何高级Java开发人员来说都是值得一读的。

Java中的线程池示例

这是Java中线程池的示例,该示例使用Java 5的Executor框架创建一个工作线程数为10的固定线程池。它将创建任务并将其提交给线程池以执行:

public class ThreadPoolExample {public static void main(String args[]) {ExecutorService service = Executors.newFixedThreadPool(10);for (int i =0; i<100; i++){service.submit(new Task(i));}}}final class Task implements Runnable{private int taskId;public Task(int id){this.taskId = id;}@Overridepublic void run() {System.out.println("Task ID : " + this.taskId +" performed by " + Thread.currentThread().getName());}}Output:
Task ID : 0 performed by pool-1-thread-1
Task ID : 3 performed by pool-1-thread-4
Task ID : 2 performed by pool-1-thread-3
Task ID : 1 performed by pool-1-thread-2
Task ID : 5 performed by pool-1-thread-6
Task ID : 4 performed by pool-1-thread-5

如果查看此Java示例的输出,则会发现线程池中正在执行任务的线程不同。

Java线程池的好处

线程池为Java应用程序提供了几项好处,其中最大的好处是将任务提交与任务执行分开,这比紧密耦合的创建和执行模式更松散,灵活。 这是在Java中使用线程池的更多好处:

  1. 线程池的使用通过避免在请求或任务处理期间创建线程来减少响应时间。
  2. 使用线程池可让您根据需要更改执行策略。 您只需替换ExecutorService实现即可从单线程切换到多线程。
  3. Java应用程序中的线程池通过创建基于系统负载和可用资源决定的配置数量的线程来提高系统的稳定性。
  4. 线程池使应用程序开发人员摆脱了线程管理的束缚,并专注于业务逻辑。

以上就是Java 5中的线程池。我们已经了解了Java中的线程池,Java 5中的执行者框架,如何在Java中创建线程池以及在Java应用程序中使用线程池的一些好处。 毫无疑问,线程池的知识对于服务器端核心Java开发人员至关重要,我建议阅读Java中的Java线程和并发实践以了解有关并发和线程池的更多信息。

本文推荐书籍

  • Brian Goeatz,Doug Leaa,Joshua Bloch和团队的实践中的Java并发
  • Java线程作者:Scott Oaks和Henry Wong
  • Joshua Bloach撰写的有效Java

参考: 如何使用Java 5 Executor框架创建线程池– Java的Javarevisited博客上的JCG合作伙伴 Javin Paul的示例教程 。

翻译自: https://www.javacodegeeks.com/2013/07/how-to-create-thread-pools-using-java-5-executor-framework.html

executor线程池框架

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

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

相关文章

第十二届蓝桥杯A组省赛试题 I: 双向排序(Java)

试题 I: 双向排序 本题总分&#xff1a;25 分 【问题描述】 给定序列 (a1, a2, , an) (1, 2, , n)&#xff0c;即 ai i。 小蓝将对这个序列进行 m 次操作&#xff0c;每次可能是将 a1, a2, , aqi 降序排列&#xff0c; 或者将 aqi , aqi1, , an 升序排列。 请求…

循环自相关函数和谱相关密度(四)——实信号、复信号模型下的QPSK信号循环谱推导

关注公号【逆向通信猿】,口令:循环谱 说明:接上一节循环自相关函数和谱相关密度(三)——实信号、复信号模型下的BPSK信号循环谱MATLAB仿真结果及代码 8 QPSK信号谱相关密度函数 8.1 实信号模型 QPSK实信号表达式可以写为 r ( t ) = y I ( t ) − y Q (

JavaFX技巧29:使布局忽略不可见的节点

在我仍在Swing中实现UI的时候&#xff0c;我曾经是MigLayout的忠实拥护者&#xff08;“一个布局管理者来统治所有这些&#xff0c;对吗Mikael&#xff1f;”&#xff09;。 我真正喜欢的功能之一是当组件不可见时可以定义不同的行为。 MigLayout允许我保留现在不可见的组件所占…

第十一届蓝桥杯A组省赛填空试题 A: 门牌制作(Java)

试题 A: 门牌制作 本题总分&#xff1a;5 分 【问题描述】 小蓝要为一条街的住户制作门牌号。 这条街一共有 2020 位住户&#xff0c;门牌号从 1 到 2020 编号。 小蓝制作门牌的方法是先制作 0 到 9 这几个数字字符&#xff0c;最后根据需要将字符粘贴到门牌上&#xff0c;例如…

循环自相关函数和谱相关密度(五)——实信号、复信号模型下的QPSK信号循环谱MATLAB仿真结果及代码

关注公号【逆向通信猿】口令:循环谱 说明:接上一节循环自相关函数和谱相关密度(四)——实信号、复信号模型下的QPSK信号循环谱推导 8.4 仿真结果 8.4.1 实QPSK信号 符号速率RB = 40,采样率Fs = 960,载波频率fc = 300,符号数N = 1000,矩形成形,二倍载波频率为符号速…

第十一届蓝桥杯A组省赛填空试题 B: 既约分数(Java)

试题 B: 既约分数 本题总分&#xff1a;5 分 【问题描述】 如果一个分数的分子和分母的最大公约数是 1&#xff0c;这个分数称为既约分数。 例如&#xff0c;3/4&#xff0c;5/2&#xff0c;1/8&#xff0c;7/1都是既约分数。 请问&#xff0c;有多少个既约分数&#xff0c;分…

C++判断是否为素数、求一个数的因数、质因数分解

判断一个数是否为素数 #include<iostream> #include<vector> #include<math.h> #include<algorithm>/*判断是否为素数*/ bool isprime(int n) {bool result;int k (int)sqrt((double)n); // 只需要循环到 √n 即可int i 0;for (i 2; i < k; i){…

新的JDK 11文件方法isSameContent()

已经建议通过JDK-8202285将名为isSameContents()方法添加到JDK 11中的Files类中[[&#xff08;fs&#xff09;向文件中添加用于比较文件内容的方法”]。 由Joe Wang提议 &#xff0c;此新方法“打算是现有isSameFile方法的扩展&#xff0c;因为它没有比较内容以回答两个文件是否…

第十一届蓝桥杯A组省赛填空试题 C: 蛇形填数(Java)

试题 C: 蛇形填数 本题总分&#xff1a;10 分 【问题描述】 如下图所示&#xff0c;小明用从 1 开始的正整数“蛇形”填充无限大的矩阵。 容易看出矩阵第二行第二列中的数是 5。请你计算矩阵中第 20 行第 20 列 的数是多少&#xff1f; 【答案提交】 这是一道结果填空的题&…

Collatz函数的C++递归实现

Collatz函数为(正)自然数定义如下&#xff1a;collatz(N)&#xff1a;如果n是偶数&#xff0c;则返回n/2&#xff0c;否则返回(n∗3)1 #include <iostream> int Collatz(int n) {if (n % 2 0)n / 2;elsen 3 * n 1;return n; }int main(int argc, char* argv[]) {if (…

AI+药物研发:人工智能赋能新药研发(人工智能应用案例)

首先&#xff0c;生物制药行业面临着两个挑战&#xff1a; 第一&#xff0c;新药研发周期很长且非常复杂&#xff1b; 第二&#xff0c;药物研发过程成本昂贵。在1950年的时候&#xff0c;十亿美元可以研发几十个药&#xff0c;到了2020年之后&#xff0c;十亿美元只能研发一个…

具有CDI和lambda的策略模式

策略设计模式在运行时动态选择一种实现算法&#xff0c;一种策略。 该模式可用于根据情况选择不同的业务算法。 我们可以将不同的算法实现定义为单独的类。 或者&#xff0c;我们利用Java SE 8 lambda和函数&#xff0c;它们在此处充当轻量级策略实现。 CDI能够注入参数化类型…

计算圆周率π的C++实现(任意精度)

π\piπ的计算公式 代码 #include <iostream> #include <corecrt_math_defines.h> #include <iomanip>double compute_pi(int N) //计算pi函数 {double dx 1.0 / N;double pi 0;for (int i 1; i < N; i){pi 2 * sqrt(1 - i * dx*i*dx); // 积分函数}…

第十一届蓝桥杯A组省赛填空试题 D: 七段码(Java)

试题 D: 七段码 本题总分&#xff1a;10 分 【问题描述】 小蓝要用七段码数码管来表示一种特殊的文字。 上图给出了七段码数码管的一个图示&#xff0c;数码管中一共有 7 段可以发光的二极管&#xff0c;分别标记为 a, b, c, d, e, f, g。 小蓝要选择一部分二极管&#xff0…

【弗雷泽岛发射站所需的最小发射功率计算】通信调制体制设计之64QAM性能分析MATLAB仿真及代码

关注公号【逆向通信猿】更精彩!!! 任务背景 弗雷泽岛旅游经理在审查您之前建立无线链路任务的解决方案时,正在研究使用无线链路传输实时安全视频源的可能性。由于来自岛周围的多个安全摄像机的视频信号在传输之前被多路复用,因此无线信道的数据速率是不同的。弗雷泽岛旅…

第十一届蓝桥杯A组省赛试题 F: 成绩分析(Java)

试题 F: 成绩分析 时间限制: 1.0s 内存限制: 512.0MB 本题总分&#xff1a;15 分 【问题描述】 小蓝给学生们组织了一场考试&#xff0c;卷面总分为 100 分&#xff0c;每个学生的得分都是 一个 0 到 100 的整数。 请计算这次考试的最高分、最低分和平均分。 【输入格式】 输…

基于代价函数小波脊相位的MFSK信号符号速率估计MATLAB仿真及代码(2020.12.14更新)

算法来源 王勇, 王李福, 邹辉,等. 一种小波脊相位提取方法: 中国专利. 仿真结果 引言 当前,脊点的选取较准确也较经典的方法是Liu等提出的里程碑式的基于代价函数的小波脊相位提取方法(即代价函数脊法),其利用代价函数来抑制噪声的影响,并结合动态规划的思想进行脊线的…

AI+社区智能管理,赋能智慧城市人情共「智」(人工智能应用案例)

社区是城市的关键组成部分&#xff0c;社区治理是围绕社区场景下的人、地、物、情、事的管理与服务。 随着城市化的快速推进及人口流动的快速增加&#xff0c;传统社区治理在人员出入管控、安防巡逻、车辆停放管理等典型场景下都面临着人力不足、效率低下、响应不及时等诸多难…

第十一届蓝桥杯A组省赛试题 G: 回文日期(Java)

试题 G: 回文日期 时间限制: 1.0s 内存限制: 512.0MB 本题总分&#xff1a;20 分 【问题描述】 2020年春节期间&#xff0c;有一个特殊的日期引起了大家的注意&#xff1a;2020年2月2日。因为如果将这个日期按 yyyymmdd 的格式写成一个8位数是 20200202 &#xff0c;恰好是一个…

多种参数的BCH、RS码和(2,1,6)卷积码编码的MATLAB仿真实现

欢迎同步关注公众号【逆向通信猿】 关于BCH码、RS码和卷积码的原理,可以查阅相关书籍资料,在此不多作赘述,有疑问可在下方留言。 MATLAB代码如下 clear;close all;clc; N=500; bit=randi([0 1],1,N);%% BCH码 %<