一:
应用程序中会出现这种情况:对服务器请求的数目非常大,但是服务器对每个请求处理的时间却很短。如果对这种情况,每个请求都创建一个线程的话,那么创建线程和销毁线程所使用的时间和资源远远大于用户请求的时间和资源,而且创建太多的线程会导致内存过度消耗从而影响性能。
而线程池很好的解决这个问题,当请求到达时,请求等待一个可用的线程,然后将任务交给线程进行执行,当任务执行完成之后,将线程返还给线程池。java.util.concurrent 是在并发编程中很常用的实用工具包,它包括互斥、信号量、诸如在并发访问下执行得很好的队列和散列表之类集合类以及几个工作队列实现。
二:
Executors类中提供了几种创建线程池的方法:
newFixedThreadPool:创建一个可重用固定线程数的线程池,当任务到来的时候会new一个线程,立马执行;如果所有的线程是活动的,新任务将在队列中等待,直到线程可用。任何线程在执行过程中终止或由于故障关断时,如果需要的话,会以一个新的线程将代替它执行后续的任务。
newSingleThreadExecutor:创建一个使用单个worker线程操作一个Executor无界队列的线程池。此线程池只有一个线程在工作,如果任务在执行过程中线程终止或故障关机,会有一个新的线程来代替它完成后续任务。此线程池保证所有任务按照提交顺序执行。
newCachedThreadPool:可根据需要创建新可缓存的线程池,对于执行很多短期异步任务的程序如果有可用线程那将重用以前构造的线程而提高性能,如果没有现有线程可用时,一个新的线程将被创建并添加到池中。如果线程池的大小超过了处理任务所需要的线程,那么就会回收部分空闲的线程。
newScheduledThreadPool:创建一个给定延迟或者定期执行的线程池。
三:
通过源码几种线程池都是通过ThreadPoolExecutor构造出来的,下面对ThreadPoolExecutor构造函数的几个参数做简单的描述:
corePoolSize - 池中所保存的线程数,包括空闲线程。
maximumPoolSize - 池中允许的最大线程数。
keepAliveTime - 当线程数大于核心时,此为终止前多余的空闲线程等待新任务的最长时间。
unit - keepAliveTime 参数的时间单位。
workQueue - 执行前用于保持任务的队列。此队列仅保持由 execute 方法提交的 Runnable 任务。
执行的步骤:
提交一个runnable任务,当poolSize(当前池的大小)<corePoolSize(池中所保存的线程数),会直接做为创建一个线程,立马执行任务。
当提交的runnable任务数超过了corePoolSize(池中所保存的线程数),会将当前的runable提交到一个块队列中。
如果块队列是有界队列,当队列满了之后如果poolSize(当前池的大小) < maximumPoolsize(池中允许的最大线程数)时,会尝试创建一个线程来进行救急处理,立马执行对应的runnable任务。
如果救急方案也无法处理了,就会执行RejectedExecutionHandler操作(进行拒绝、抛弃、抛弃队列最早的、调用运行)。
四:简单例子
public abstract class AbstractChannelMessageProcessor {
/**
* 线程池
*/
private ScheduledExecutorService scheduledExecutorService;
public AbstractChannelMessageProcessor(){
scheduledExecutorService = Executors.newScheduledThreadPool(1000);
}
/**
* 处理延迟的功能
* @author wjy
* @since 2013-12-12
*/
class CreateTaoKeCtProfitInfo implements Runnable{
private Map<Long,BizOrderDO> bizOrderIdMap;
CreateTaoKeCtProfitInfo(Map<Long,BizOrderDO> bizOrderIdMap){
this.bizOrderIdMap = bizOrderIdMap;
}
public void run() {
//进行处理的代码。。。。。。。
}
}
/**
* 运用newScheduledThreadPool来延迟操作(延迟5分钟)
* @param bizOrderIdMap
*/
public void createCtProfitInfoForTaoKe(Map<Long,BizOrderDO> bizOrderIdMap){
scheduledExecutorService.schedule(new CreateTaoKeCtProfitInfo(bizOrderIdMap), 5, TimeUnit.MINUTES);//
}
}
相关推荐
线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池...
corePoolSize:核心池的大小,在创建了线程池后,线程池中的线程数为0,当有任务来之后,就会创建一个线程去执行任务,当线程池中的线程数目达到corePoolSize后,就会把到达的任务放到缓存队列当中; ...
阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池...
一、线程池 1、为什么需要使用线程池 1.1 创建/销毁线程伴随着系统开销,过于频繁的创建/销毁线程,会很大程度上影响处理效率。 记创建线程消耗时间T1,执行任务消耗时间T2,销毁线程消耗时间T3,如果T1+T3>T2,那...
VC实现线程池
易语言简易线程池的实现。 ——V雪落有声V原创。转载请保留。前文:。为了能充分理解本篇文章的内容,需要了解的知识如下:。1.事件对象的使用:http://baike.baidu.com/view/751499.htm。2.信号量的使用:...
简单的线程池程序+中文文档 包结构: com.tangkai.threadpool --SimpleThread.java 工作线程 --TestThreadPool.java 程序入口 --ThreadPoolManager.java 线程池管理类
Windows下一个比较完美的线程池实现和示例 本线程池提供了如下功能: 1.能根据任务个数和当前线程的多少在最小/最大线程个数之间自动调整(Vista后的系统有 SetThreadpoolThreadMaximum 等函数有类似功能); 2.能方便...
C#管理线程池的类 /* How to use Thread Classs * * ============== * public ELMService() { InitializeComponent(); etm.ClalThreadPool("EmailThreads", (uint)ApplicationInfo.EmailParsingThreads); ...
线程池
因为本人是个小白,多线程经常用,但是线程池并没有用过,(一听到线程池,总感觉高大上)。但是近期写彩票软件的时候发现,多线程长期操作会导致内容不断的升高直至报错,遂想起了线程池,完善后发现不是一般的叼...
2.然后根据提示运行java命令执行示例程序,观看线程池的运行结果 目标:Java中多线程技术是一个难点,但是也是一个核心技术。因为Java本身就是一个多线程语言。本人目前在给46班讲授Swing的网络编程--使用Swing来...
一、要实现高效的线程池,可以考虑以下几点 二、实现线程池可以按照以下步骤进行 三、简单的C++线程池代码示例 四、 基于boost编写的源码库 - 线程池 4.1 基于boost编写的源码库地址 4.2 boost线程池的先进先出、...
1.线程池管理器(ThreadPoolManager):用于创建并管理线程池 2.工作线程(WorkThread): 线程池中线程 3.任务接口(Task):每个任务必须实现的接口,以供工作线程调度任务的执行。 4.任务队列:用于存放没有处理的...
以下示例显示如何使用线程池。首先创建 ManualResetEvent 对象,此对象使程序能够知道线程池何时运行完所有的工作项。接着,尝试向线程池添加一个线程。如果添加成功,则添加其余的线程(本例中为 4 个)。然后...
linux线程池创建c实现 linux线程池创建c实现 linux线程池创建c实现 linux线程池创建c实现 linux线程池创建c实现 linux线程池创建c实现
使用Windows自带的线程池功能,比你写的线程池性能好得多
什么是线程池?简单点说,线程池就是有一堆已经创建好了的线程,初始它们都处于空闲等待状态,当有新的任务需要处理的时候,就从这个池子里面取一个空闲等待的线程来处理该任务,当处理完成了就再次把该线程放回池中...
这是一个简单线程池的实现,虽然有很多bug,但是能够简单地实现线程池。
Java开发,Android开发,自己实现线程池,明白线程池的实现机制