【JAVA中级篇】线程池

上一篇文章已经介绍了线程的基本概念以及线程相关的API,下面来看一下线程池

一、线程池框架

1、线程池的优点

  1. 重用线程池中的线程,避免因为线程的创建和销毁所带来的性能开销。 
  2. 能有效控制线程池的最大并发数,避免大量线程之间因互相抢夺系统资源而导致的阻塞现象。 
  3. 能够对线程进行简单的管理,并提供定时执行以及指向间隔循环执行等功能。

2、JAVA中相关类

Executor是一个顶层接口,它里面只声明了一个方法execute(Runnable)

ExecutorService接口继承了Executor接口,并且声明了一些方法:submit、invokeAll、invokeAny以及shutDown等AbstractExecutorService实现了ExecutorService接口,基本实现了ExecutorService中声明的所有方法

ThreadPoolExecutor接口继承了AbstractExecutorService这个类,并且实现了这些重要方法:execute() 、shutdown()、shutdownNow()

Executors提供了大量的static方法,来创建各种特性的线程池(基于ThreadPoolExecutor的构造方法)、大量的callable方法和创建ThreadFactory的方法

ThreadPoolExecutor的重要属性

    private final BlockingQueue<Runnable> workQueue;//任务缓存队列,用来存放等待执行的任务private final ReentrantLock mainLock = new ReentrantLock();//线程池的主要状态锁,对线程池状态(比如线程池大小、runState等)的改变都要使用这个锁private final HashSet<Worker> workers = new HashSet<Worker>();//用来存放工作集private final Condition termination = mainLock.newCondition();//private int largestPoolSize;//用来记录线程池中曾经出现过的最大线程数private long completedTaskCount;//用来记录已经执行完毕的任务个数private volatile ThreadFactory threadFactory;//线程工厂,用来创建线程private volatile RejectedExecutionHandler handler;//任务拒绝策略private volatile long keepAliveTime;//线程存活时间 private volatile boolean allowCoreThreadTimeOut;//是否允许为核心线程设置存活时间private volatile int corePoolSize;//核心池的大小(即线程池中的线程数目大于这个参数时,提交的任务会被放进任务缓存队列)private volatile int maximumPoolSize;//线程池最大能容忍的线程数private static final RejectedExecutionHandler defaultHandler =new AbortPolicy();//默认的任务拒绝策略private static final RuntimePermission shutdownPerm =new RuntimePermission("modifyThread");

这里要重点解释一下corePoolSize、maximumPoolSize、largestPoolSize三个变量。

corePoolSize在很多地方被翻译成核心池大小,其实我的理解这个就是线程池的大小。举个简单的例子:

  假如有一个工厂,工厂里面有10个工人,每个工人同时只能做一件任务。

  因此只要当10个工人中有工人是空闲的,来了任务就分配给空闲的工人做;

  当10个工人都有任务在做时,如果还来了任务,就把任务进行排队等待;

  如果说新任务数目增长的速度远远大于工人做任务的速度,那么此时工厂主管可能会想补救措施,比如重新招4个临时工人进来;

  然后就将任务也分配给这4个临时工人做;

  如果说着14个工人做任务的速度还是不够,此时工厂主管可能就要考虑不再接收新的任务或者抛弃前面的一些任务了。

  当这14个工人当中有人空闲时,而新任务增长的速度又比较缓慢,工厂主管可能就考虑辞掉4个临时工了,只保持原来的10个工人,毕竟请额外的工人是要花钱的。

  这个例子中的corePoolSize就是10,而maximumPoolSize就是14(10+4)。

  也就是说corePoolSize就是线程池大小,maximumPoolSize在我看来是线程池的一种补救措施,即任务量突然过大时的一种补救措施。

  不过为了方便理解,在本文后面还是将corePoolSize翻译成核心池大小。

  largestPoolSize只是一个用来起记录作用的变量,用来记录线程池中曾经有过的最大线程数目,跟线程池的容量没有任何关系。

重要方法

execute

    public void execute(Runnable command) {if (command == null)throw new NullPointerException();int c = ctl.get();if (workerCountOf(c) < corePoolSize) {if (addWorker(command, true))return;c = ctl.get();}if (isRunning(c) && workQueue.offer(command)) {int recheck = ctl.get();if (! isRunning(recheck) && remove(command))reject(command);else if (workerCountOf(recheck) == 0)addWorker(null, false);}else if (!addWorker(command, false))reject(command);}

3、线程池的分类

newFixedThreadPool

newWorkStealingPool

newSingleThreadExecutor

newCachedThreadPool

newSingleThreadScheduledExecutor

newScheduledThreadPool

重点是ThreadPoolExecutor的代码、还需要理解线程池状态、任务的执行、线程池中的线程初始化、任务缓存队列及排队策略、任务拒绝策略、线程池的关闭、线程池容量的动态调整

简单使用Demo

package com.demo;import java.util.ArrayList;
import java.util.Collection;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ThreadPool {   private int threadCount = 10;private int threadpoolCount = 3;public static void main(String[] args) {new ThreadPool().threadPoolControl();}public void threadPoolControl() {       ThreadObject[] et = new ThreadObject[threadCount];       ExecutorService service = Executors.newFixedThreadPool(threadpoolCount);Collection<ThreadObject> c = new ArrayList<ThreadObject>();for (int i = 0; i < threadCount; i++) {   et[i] = new ThreadObject();           c.add(et[i]);}try {service.invokeAll(c);service.shutdown();} catch (InterruptedException e) {e.printStackTrace();}}class ThreadObject implements Callable<Object>{       public Object call() throws Exception {System.out.println("当前线程:"+Thread.currentThread().getName()+",线程对象:"+this);return null;}}
}

 

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

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

相关文章

kafka 脚本发送_Kafka笔记归纳(第五部分:一致性保证,消息重复消费场景及解决方式)...

写在开头&#xff1a;本章是Kafka学习归纳第五部分&#xff0c;着重于强调Kafka的事一致性保证&#xff0c;消息重复消费场景及解决方式&#xff0c;记录偏移量的主题&#xff0c;延时队列的知识点。文章内容输出来源&#xff1a;拉勾教育大数据高薪训练营。一致性保证水位标记…

【Java基础篇】集合排序

所谓集合排序是指对集合内的元素进行排序。 集合工具类Collections中提供了两种排序算法&#xff0c;分别是&#xff1a; Collections.sort(List list)Collections.sort(List list,Comparator c) Collections.sort(List list)这种方式需要对象实现Comparable接口&#xff0c;…

语言nomogram校准曲线图_预测模型的概率校准

1.背景 机器学习分为:监督学习,无监督学习,半监督学习(也可以用hinton所说的强化学习)等。在这里,先简要介绍一下监督学习从给定的训练数据集中学习出一个函数(模型参数),当新的数据到来时,可以根据这个函数预测结果。监督学习的训练集要求包括输入输出,也可以说是特征和…

eclipse debug 工程源码时出现source not found问题解决

问题描述&#xff1a;使用eclipse debug启动应用&#xff0c;并且打断点在工程的源码上面&#xff0c;提示source not found。 问题解决&#xff1a; 1、选中工程&#xff0c;右键Debug As》Debug Configurations 2、在Java Application下面选中需要debug的程序&#xff0c;然…

代码中有个get是啥意思_是时候秀一波了,甩掉get和set,Lombok让代码更简洁

前言前几天有个新来的同事(实习生)惊讶的对我说&#xff1a;我们的代码里好多错误&#xff0c;我的程序本地都启动不了。我一脸懵逼的质问他&#xff1a;目前线上的代码&#xff0c;怎么会有问题吗&#xff1f;他不服气的说&#xff1a;你来看嘛&#xff0c;就是有问题&#xf…

JavaWeb工程师知识图谱

一个工作快三年的的Java菜鸟&#xff0c;总结梳理了一下JavaWeb工程师必须掌握的一些知识点&#xff08;持续更新中。。。&#xff09;。 预览效果 xmind原始文件 百度云盘 链接&#xff1a;https://pan.baidu.com/s/1hp3MWGOX2I8APw75Suu52Q 提取码&#xff1a;j6w6

【Java中级篇】基于jxl读写Excel文件遇到的问题

发生异常&#xff0c;并且提示&#xff1a;unable to recognize ole stream 遇到这个问题需要将Excel文件另存为Excel 97-2003&#xff08;*.xls&#xff09;

松下a6伺服x4接线图_2021中山东凤松下温控器回收价高同行

2021中山东凤松下温控器回收价高同行西门子TDC&#xff0c;西门子存储卡,西门子变频器等全线西门子自动化产品。小汪 满意的价格&#xff0c;快的付款速度&#xff0c;热诚欢迎全国各地朋友洽谈合作。具体回收业务&#xff1a;SIEMENS可编程控制器 1、SIMATIC&#xff0c;S7系列…

eclipse启动发生Failed to load JNI shared library

今天启动eclipse发生下面的情况 从网上知道是eclipse和jdk位数不一致导致的。 输入java -version ,查看JDK是多少位&#xff0c;显示64位的就是64位JDK&#xff0c;未显示的为32位的JDK。 eclipse的安装目录下有一个叫eclipse.ini的配置文件&#xff0c;打开后能看到 x86_64说…

imx226_相机选型器

-- 全部 --AR1820HS (8)CMV2000-2E5C1PP (2)CMV2000-3E12M1PP (2)CMV2000-3E5M1PP (2)CMV4000-3E12M1PP (1)CMV4000-3E5C1PP (5)CMV4000-3E5M1PP (5)EV76C560ABT (25)EV76C560ACT (25)EV76C570ABT (23)EV76C570ACT (23)EV76C661ABT (20)IMX174LLJ-C (8)IMX174LQJ-C (8)IMX178LL…

算法的时间复杂度和空间复杂度的原理

一、算法分析 如何判断一个算法的好坏呢&#xff1f;首先算法必须要正确&#xff0c;这是最基本的要求。其次&#xff1a; 算法花费的时间算法占用的空间小&#xff08;辅助存储空间&#xff09;算法要容易调试&#xff0c;测试&#xff0c;理解&#xff0c;编码&#xff0c;…

5条件筛选功能_一分钟,彻底学会Excel高级筛选,坐等升职加薪!

Excel中高级筛选是普通筛选的加强&#xff0c;能够实现更加复杂的筛选功能。请您看下面的示例图&#xff1a;数据示例图如果要求筛选出班级为2班且语文成绩大于100分的数据&#xff0c;那么使用普通筛选连续筛选两次就可以得到结果。请您看下面的操作演示&#xff1a;普通筛选操…

数据结构之树【完善中】

一、树的概念 树是一种分组的层次结构。 树的定义&#xff1a; 树是n(n>0)个数据元素的集合,在任意一棵非空树中&#xff0c;有如下特征 有且只有一个根结点&#xff08;无前驱结点&#xff09;当n>1时&#xff0c;其他结点被分为若干个互不相交集合&#xff0c;并且…

phpgif图片包_PHP生成GIF动态图片验证码

1 <?php2 /**3 * 调用示例4 **/5 session_start();6 $randCode ;7 //验证码随机8 $str"abcdefghjkmnpqrstuvwsyzABCDEFGHJKMNPQRSTUVWSYZ23456789";9 for($i0;$i<4;$i){10 $safe.substr($str,rand(0,strlen($str)),1);11 }12 $_SESSION["imgcode"]…

工程图标注粗糙度_Inventor教程之工程图标注实例

1工程图标注实例对以下实体零件进行全部的标注演示。操作步骤如下&#xff1a;(1)打开文件。运行Inventor&#xff0c;单击“快速入门”选项卡“启动”面板上的“打开”按钮&#xff0c;在“打开”对话框中选择“实体零件”&#xff0c;单击“打开”按钮进入实体零件。(2)新建工…

Oracle数据库 invalid character问题解决

今天使用PL/SQL Developer这个工具来操作Oracle数据时发现了一个问题&#xff1a; select * from tb_student_grade pivot(max(grade) for course in(math as 数学,chinese as 语文,english as 英语)); 执行这个SQL语句提示invalid character,原因是我的数据库编码是AMERICAN…

定时线程_SpringBoot定时任务,@Async多线程异步执行

一、使用SpringBoot实现定时任务这个不是重点&#xff0c;就简单的实现一下&#xff0c;至于cron表达式怎么写也不是重点&#xff0c;自行百度即可。1-1、基于 Scheduled 注解的方式import org.springframework.scheduling.annotation.EnableScheduling;import org.springframe…

SpringBoot入门一

SpringBoot能够很简单的创建一个直接运行的单体Spring应用 特性&#xff1a; 单体Spring应用内置的tomcat、Jetty提供默认的starter来构建配置自动配置Spring和第三方库 推荐一个很好的学习教程&#xff0c;https://blog.csdn.net/u010486495/article/details/79348302 1 构…

mysql怎么把datetime类型转换_mysql怎样实现time转datetime

mysql实现time转datetime的方法&#xff1a;使用在sql语句中【FROM_UNIXTIME(时间值)】&#xff0c;代码为【insert into test(time) values(FROM_UNIXTIME(%d))",time(NULL)】。mysql实现time转datetime的方法&#xff1a;FROM_UNIXTIME(time(NULL))将liunx系统的time_t类…

SpringBoot入门二

参考Spring Boot Starters - 御坂研究所 创建自己的starter starter是依赖的一种synthesize&#xff08;合成&#xff09;。 starter会把需要用到的依赖全部包含进来&#xff0c;避免开发者自己手动引入依赖。 starter的逻辑 pom.xml<parent><groupId>org.spri…