java线程池的设计思想
ExecutorService executorForFM = new ThreadPoolExecutor(500, 800, 2L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>(7000));由这个线程池执行上面的两个任务集合,参数说明500个核心线程他会一直在线程池中的,800核心线程是线程池容纳最大数目,2毫秒表示线程池中如果大于核心线程数目那么闲散的线程会在2两毫秒终止线程(在没有接受新任务的情况下) 1、如果线程池中运行的线程 小于corePoolSize ,即使线程池中的线程都处于空闲状态,也要 创建新的线程 来处理 被添加的任务。 2、如果线程池中运行的线程大于等于corePoolSize,但是缓冲队列 workQueue未满 ,那么任务被放入缓冲队列 。 3、如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满(即无法将请求加入队列 ),并且线程池中 的数量小于maximumPoolSize,建新的线程 来处理被添加的任务。 如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量等于 maximumPoolSize ,那么通过 handler 所指定的策略来处理此任务。( ThreadPoolExecutor.AbortPolicy()//抛出java.util.concurrent.RejectedExecutionException异常ThreadPoolExecutor.CallerRunsPolicy()//重试添加当前的任务,他会自动重复调用execute()方法ThreadPoolExecutor.DiscardOldestPolicy()//抛弃旧的任务ThreadPoolExecutor.DiscardPolicy()// 抛弃当前的任务)4、当线程池中的线程数量大于 corePoolSize时,如果某线程空闲时间超过keepAliveTime,线程将被终止 。这样, 线程池可以动态的调整池中的线程数。http://dl.iteye.com/upload/attachment/0070/2826/8ee1a63c-f0f6-3187-bda6-06a8ea5408ea.jpg
http://dl.iteye.com/upload/attachment/0070/2828/afdd699b-4100-3120-80d8-b68b004cfa72.jpg
页:
[1]