关于线程池ThreadPoolExecutor使用总结

本文引用自:

http://blog.chinaunix.net/uid-20577907-id-3519578.html 

 

一、简介 
线程池类为 java.util.concurrent.ThreadPoolExecutor,常用构造方法为: 

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue workQueue, RejectedExecutionHandler handler) 
corePoolSize: 线程池维护线程的最少数量 
maximumPoolSize:线程池维护线程的最大数量 
keepAliveTime: 线程池维护线程所允许的空闲时间 
unit: 线程池维护线程所允许的空闲时间的单位 
workQueue: 线程池所使用的缓冲队列 
handler: 线程池对拒绝任务的处理策略 

一个任务通过 execute(Runnable)方法被添加到线程池,任务就是一个 Runnable类型的对象,任务的执行方法就是 Runnable类型对象的run()方法。 

当一个任务通过execute(Runnable)方法欲添加到线程池时: 
如果此时线程池中的数量小于corePoolSize,即使线程池中的线程都处于空闲状态,也要创建新的线程来处理被添加的任务。 
如果此时线程池中的数量等于 corePoolSize,但是缓冲队列 workQueue未满,那么任务被放入缓冲队列。 
如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量小于maximumPoolSize,建新的线程来处理被添加的任务。 
如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量等于maximumPoolSize,那么通过 handler所指定的策略来处理此任务。 

 

也就是:处理任务的优先级为: 
核心线程corePoolSize、任务队列workQueue、最大线程maximumPoolSize,如果三者都满了,使用handler处理被拒绝的任务。 

当线程池中的线程数量大于 corePoolSize时,如果某线程空闲时间超过keepAliveTime,线程将被终止。这样,线程池可以动态的调整池中的线程数。 

unit可选的参数为java.util.concurrent.TimeUnit中的几个静态属性: NANOSECONDS、MICROSECONDS、MILLISECONDS、SECONDS。 

workQueue我常用的是:java.util.concurrent.ArrayBlockingQueue 

handler有四个选择: 
ThreadPoolExecutor.AbortPolicy() 
抛出java.util.concurrent.RejectedExecutionException异常 
ThreadPoolExecutor.CallerRunsPolicy() 
重试添加当前的任务,他会自动重复调用execute()方法 
ThreadPoolExecutor.DiscardOldestPolicy() 
抛弃旧的任务 
ThreadPoolExecutor.DiscardPolicy() 
抛弃当前的任务 

 

二、一般用法举例 

 1 import java.io.Serializable;
 2 import java.util.concurrent.ArrayBlockingQueue;
 3 import java.util.concurrent.ThreadPoolExecutor;
 4 import java.util.concurrent.TimeUnit;
 5 
 6 public class TestThreadPool {
 7 
 8     private static int produceTaskSleepTime = 2;
 9 
10     private static int produceTaskMaxNumber = 10;
11 
12     public static void main(String[] args) {
13         // 构造一个线程池
14         ThreadPoolExecutor threadPool = new ThreadPoolExecutor(2, 4, 3, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(3),
15                 new ThreadPoolExecutor.DiscardOldestPolicy());
16 //        corePoolSize: 线程池维护线程的最少数量 ==============>2
17 //        maximumPoolSize:线程池维护线程的最大数量 ==============>4 
18 //        keepAliveTime: 线程池维护线程所允许的空闲时间 ==============>3
19 //        unit: 线程池维护线程所允许的空闲时间的单位 ==============>TimeUnit.SECONDS
20 //        workQueue: 线程池所使用的缓冲队列 ==============>new ArrayBlockingQueue<Runnable>(3)
21 //        handler: 线程池对拒绝任务的处理策略 ==============>new ThreadPoolExecutor.DiscardOldestPolicy()
22 
23         for (int i = 1; i <= produceTaskMaxNumber; i++) {
24             try {
25                 // 产生一个任务,并将其加入到线程池
26                 String task = "task@ " + i;
27                 System.out.println("put " + task);
28                 threadPool.execute(new ThreadPoolTask(task));
29 
30                 // 便于观察,等待一段时间
31                 Thread.sleep(produceTaskSleepTime);
32             } catch (Exception e) {
33                 e.printStackTrace();
34             }
35         }
36     }
37 }
38 
39 /**
40  * 线程池执行的任务
41  */
42 class ThreadPoolTask implements Runnable, Serializable {
43 
44     private static final long serialVersionUID = 0;
45 
46     private static int consumeTaskSleepTime = 2000;
47 
48     // 保存任务所需要的数据
49     private Object threadPoolTaskData;
50 
51     ThreadPoolTask(Object tasks) {
52         this.threadPoolTaskData = tasks;
53     }
54 
55     public void run() {
56         // 处理一个任务,这里的处理方式太简单了,仅仅是一个打印语句
57         System.out.println(Thread.currentThread().getName());
58         System.out.println("start .." + threadPoolTaskData);
59 
60         try {
61             //便于观察,等待一段时间
62             Thread.sleep(consumeTaskSleepTime);
63         } catch (Exception e) {
64             e.printStackTrace();
65         }
66         threadPoolTaskData = null;
67     }
68 
69     public Object getTask() {
70         return this.threadPoolTaskData;
71     }
72 }

 

说明: 
1、在这段程序中,一个任务就是一个Runnable类型的对象,也就是一个ThreadPoolTask类型的对象。 
2、一般来说任务除了处理方式外,还需要处理的数据,处理的数据通过构造方法传给任务。 
3、在这段程序中,main()方法相当于一个残忍的领导,他派发出许多任务,丢给一个叫 threadPool的任劳任怨的小组来做。 
这个小组里面队员至少有两个,如果他们两个忙不过来,任务就被放到任务列表里面。 
如果积压的任务过多,多到任务列表都装不下(超过3个)的时候,就雇佣新的队员来帮忙。但是基于成本的考虑,不能雇佣太多的队员,至多只能雇佣 4个。 
如果四个队员都在忙时,再有新的任务,这个小组就处理不了了,任务就会被通过一种策略来处理,我们的处理方式是不停的派发,直到接受这个任务为止(更残忍!呵呵)。 
因为队员工作是需要成本的,如果工作很闲,闲到 3SECONDS都没有新的任务了,那么有的队员就会被解雇了,但是,为了小组的正常运转,即使工作再闲,小组的队员也不能少于两个。 
4、通过调整 produceTaskSleepTime和 consumeTaskSleepTime的大小来实现对派发任务和处理任务的速度的控制,改变这两个值就可以观察不同速率下程序的工作情况。 
5、通过调整4中所指的数据,再加上调整任务丢弃策略,换上其他三种策略,就可以看出不同策略下的不同处理方式。 
6、对于其他的使用方法,参看jdk的帮助,很容易理解和使用。 

 

另一个例子: 

 1 import java.util.Queue;
 2 import java.util.concurrent.ArrayBlockingQueue;
 3 import java.util.concurrent.ThreadPoolExecutor;
 4 import java.util.concurrent.TimeUnit;
 5 
 6 public class ThreadPoolExecutorTest {
 7 
 8     private static int queueDeep = 4;
 9 
10     public void createThreadPool() {
11         /*
12          * 创建线程池,最小线程数为2,最大线程数为4,线程池维护线程的空闲时间为3秒, 使用队列深度为4的有界队列,如果执行程序尚未关闭,则位于工作队列头部的任务将被删除,
13          * 然后重试执行程序(如果再次失败,则重复此过程),里面已经根据队列深度对任务加载进行了控制。
14          */
15         ThreadPoolExecutor tpe = new ThreadPoolExecutor(2, 4, 3, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(queueDeep),
16                 new ThreadPoolExecutor.DiscardOldestPolicy());
17 
18         // 向线程池中添加 10 个任务
19         for (int i = 0; i < 10; i++) {
20             try {
21                 Thread.sleep(1);
22             } catch (InterruptedException e) {
23                 e.printStackTrace();
24             }
25             while (getQueueSize(tpe.getQueue()) >= queueDeep) {
26                 System.out.println("队列已满,等3秒再添加任务");
27                 try {
28                     Thread.sleep(3000);
29                 } catch (InterruptedException e) {
30                     e.printStackTrace();
31                 }
32             }
33             TaskThreadPool ttp = new TaskThreadPool(i);
34             System.out.println("put i:" + i);
35             tpe.execute(ttp);
36         }
37 
38         tpe.shutdown();
39     }
40 
41     private synchronized int getQueueSize(Queue queue) {
42         return queue.size();
43     }
44 
45     public static void main(String[] args) {
46         ThreadPoolExecutorTest test = new ThreadPoolExecutorTest();
47         test.createThreadPool();
48     }
49 
50     class TaskThreadPool implements Runnable {
51 
52         private int index;
53 
54         public TaskThreadPool(int index) {
55             this.index = index;
56         }
57 
58         public void run() {
59             System.out.println(Thread.currentThread() + " index:" + index);
60             try {
61                 Thread.sleep(3000);
62             } catch (InterruptedException e) {
63                 e.printStackTrace();
64             }
65         }
66     }
67 }

 

转载于:https://www.cnblogs.com/DreamDrive/p/4758260.html

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

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

相关文章

AIoT重磅报告:四大关键助力,AI+IoT重新定义未来的可能性

来源&#xff1a;北京物联网智能技术应用协会,智能巅峰导 读随着科技的不断发展&#xff0c;一些在功能上具有相互补充作用的技术正在不可避免地发生结合——例如&#xff0c;人工智能&#xff08;AI&#xff09;和物联网&#xff08;IoT&#xff09;。在本文中&#xff0c;我…

python---aiohttp库

python—aiohttp库 1. 什么事aiohttp 官方网址&#xff1a;https://docs.aiohttp.org/en/stable/ 用于asyncio和Python的异步HTTP客户端/服务器 2. 安装 pip install aiohttp3. ClientSession() Session封装了一个连接池&#xff08;connector instance&#xff09;&…

关于机器学习实战,那些教科书里学不到的12个“民间智慧”

来源&#xff1a;towardsml机器学习算法被认为能够通过学习数据来弄清楚如何执行重要任务。这意味着数据量越大&#xff0c;这些算法就可以解决更加复杂的问题。然而&#xff0c;开发成功的机器学习应用程序需要一定的“民间技巧”&#xff0c;这在教科书或机器学习入门课程中很…

asp.net winform 实现复制,粘贴,剪切功能

System.Windows.Forms.SendKeys.SendWait("^C");//复制System.Windows.Forms.SendKeys.SendWait("^V");//粘贴 System.Windows.Forms.SendKeys.SendWait("^X");//剪切转载于:https://www.cnblogs.com/ninestart/p/4760801.html

aiohttp.client_exceptions.ServerDisconnectedError: Server disconnected

aiohttp.client_exceptions.ServerDisconnectedError: Server disconnected 问题描述&#xff1a; 使用 aiohttp.ClientSession() 爬取数据时出现错误&#xff1a;aiohttp.client_exceptions.ServerDisconnectedError: Server disconnected。 翻译&#xff1a;aiohttp.client_e…

jsonp模拟获取百度搜索相关词汇

随便写了个jsonp模拟百度搜索相关词汇的小demo&#xff0c;帮助新手理解jsonp的用法。 <!DOCTYPE html><html lang"en"><head><meta charset"UTF-8"><title>模拟百度搜索框</title><style>*{margin: 0;padding:…

亚马逊自动打包机:1机可顶24人

来源&#xff1a;网易科技5月14日据国外媒体报道&#xff0c;电商亚马逊公司正在推出能够自动打包订购商品的机器&#xff0c;从而解放数千名员工。该项目的两名工作人员表示&#xff0c;亚马逊近年来开始在少数几个仓库中增加这项技术&#xff0c;扫描从传送带上下来的货物&am…

Pyinstaller打包Django项目

1. 安装pyinstaller pip install pyinstaller2. 介 绍 PyInstaller读取您编写的 Python 脚本。它会分析您的代码以发现您的脚本需要执行的所有其他模块和库。然后它收集所有这些文件的副本——包括活动的 Python 解释器&#xff01;– 并将它们与您的脚本放在一个文件夹中&am…

活着不易,5G时代终端厂商的路在何方?

来源&#xff1a;物联网智库摘要&#xff1a;站在“浮尸遍地”的通信终端的世界里&#xff0c;各大终端厂商无不面临着同一个来自灵魂的拷问&#xff1a;活着不易&#xff0c;5G时代终端厂商的路在何方&#xff1f;从1G模拟通信时代到4G移动宽带时代&#xff0c;全球手机终端厂…

图像处理 --- 一、认识图像处理

声明&#xff1a; 本系列文档由学习哔站视频总结而得&#xff0c;后续会逐渐添加相对应的示例代码&#xff08;python&#xff09; 1. 什么是图像与图像处理 百闻不如一见。 图像是客观对象的一种相似性的、生动性的描述或写真&#xff0c;是人类社会活动中最常用的信息载体…

tf.gfile()函数

转自https://blog.csdn.net/pursuit_zhangyu/article/details/80557958 这些函数和python中的os模块非常的相似&#xff0c;一般都可以用os模块代替吧 gfile API介绍 下面将分别介绍每一个gfile API&#xff01; 2-1&#xff09;tf.gfile.Copy(oldpath, newpath, overwrite…

Web安全解决方案

什么是 .NET Framework 安全性? .NET Framework 提供了用户和代码安全模型&#xff0c;允许对用户和代码可以执行的操作进行限制。要对基于角色的安全性和代码访问安全性进行编程&#xff0c;可以从 System.Security 命名空间中使用类型。.NET Framework 还提供了System.Secur…

11款新品,一切为了落地!商汤:普惠AI的时代,来了

来源&#xff1a;网易智能北京时间5月15日&#xff0c;商汤科技在京举办一年一度的人工智能峰会&#xff0c;发布了11款新品&#xff0c;包含6款硬件和多个平台的全面升级。商汤科技CEO徐立在开场演讲中以清明上河图为例&#xff0c;认为人工智能技术的普及正在谱写新时代的人类…

图像处理 --- 二、数字图像处理基础

1. 色度学基础 电磁光波谱组成: 1.1 三基色原理 人眼的视网膜上存在大量能在适当亮度下分辨颜色的锥状细胞&#xff0c;它们分别对应红、绿、蓝三种颜色&#xff0c;即分别对红光、绿光、蓝光敏感。由此&#xff0c;红&#xff08;R&#xff09;、绿&#xff08;G&#xff09;…

Bug调试(lldb)

原文网址&#xff1a;http://www.cnblogs.com/Twisted-Fate/p/4760156.html 今天博主有一些Bug调试的需求,遇到了一些困难点,在此和大家分享,希望能够共同进步. Xcode的Bug调试方法大概有以下几种: 1.断点,全局断点,条件断点配合Nslog找出Bug 2.静态分析工具:Analyze,静态检测内…

解密!谷歌这样搞定美军世纪难题,从眼科诊断到无人驾驶

来源&#xff1a;智东西导语&#xff1a;谷歌AI部门负责人Jeff Dean&#xff0c;在开发者大会中详细介绍了该公司如何利用AI技术解决科学问题。5月14日消息&#xff0c;在加利福尼亚州山景城举行的谷歌年度I / O开发者大会上&#xff0c;谷歌研究小组高级研究员、谷歌人工智能部…

CSDN中图片缩放与居中

1. 直接上传图片 代码示例&#xff1a; ![在这里插入图片描述](https://img-blog.csdnimg.cn/20210628233911771.png?x-oss-processimage/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYl9mZW5n,size_16,color_FFFFFF,t_70#pic_cent…

tensorflow中创建多个计算图(Graph)

转自https://blog.csdn.net/dcrmg/article/details/79028032 tf中可以定义多个计算图&#xff0c;不同计算图上的张量和运算是相互独立的&#xff0c;不会共享。计算图可以用来隔离张量和计算&#xff0c;同时提供了管理张量和计算的机制。计算图可以通过Graph.device函数来指…

文体中心场地预订小程序开发笔记-功能设计

首页 1.推荐活动&#xff1a; 展示最新、最受欢迎或即将举办的文体活动。2.新闻与公告&#xff1a; 提供关于文体中心的最新新闻和通知。 活动浏览与报名 3.活动列表&#xff1a; 用户可以查看文体中心的各类文体活动&#xff0c;包括体育赛事、文艺演出、培训课程等。4.活动…

【剑指offer】面试题40:数组中只出现一次的数字

题目&#xff1a; 一个整型数组里除了两个数字之外&#xff0c;其他的数字都出现了两次。请写程序找出这两个只出现一次的数字。 思路&#xff1a; 因为只有两个只出现一次的数字&#xff0c;所以所有数字进行异或之后得到值res一定不是0.这样&#xff0c;res中其中至少1bit不是…