并发包的线程池第二篇--Executors的构造

上一篇讲述了ThreadPoolExecutor的执行过程,我们也能看出来一个很明显的问题:这个线程池的构造函数比较复杂,对于不十分理解其运作原理的程序员,自己构造它可能体现和想象中不一样的行为。比如阻塞队列放什么,corePoolSize怎么设置等等。

所以和Math这种工具类一样,并发包也提供了一种工具类:Executors。

首先这个工具类的作用就是:提供静态方法帮你构造不同的线程池。那么先分析一下它的设计模式:

1,静态工厂方法模式,静态方法帮你构造线程池。

2,外观模式,用一个简单的接口屏蔽了内部细节。(这么说有一点点牵强)

这个Executors提供的最主要的工厂有三种:

 1     public static ExecutorService newFixedThreadPool(int nThreads) {
 2         return new ThreadPoolExecutor(nThreads, nThreads,
 3                                       0L, TimeUnit.MILLISECONDS,
 4                                       new LinkedBlockingQueue<Runnable>());
 5     }
 6
 7     public static ExecutorService newSingleThreadExecutor() {
 8         return new FinalizableDelegatedExecutorService
 9             (new ThreadPoolExecutor(1, 1,
10                                     0L, TimeUnit.MILLISECONDS,
11                                     new LinkedBlockingQueue<Runnable>()));
12     }
13
14     public static ExecutorService newCachedThreadPool() {
15         return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
16                                       60L, TimeUnit.SECONDS,
17                                       new SynchronousQueue<Runnable>());
18     }

第一种:大小固定的线程池,构造的时候必须告知其最大线程数量(无论如何也不超过这个数字),同时corePoolSize和maximumPoolSize都直接设置为这个最大线程数目参数。keepAliveTime则设置为0。(更本没有“短工”,也就谈不上短工的成活时间了)

重要的来了:为什么阻塞队列是一个无界队列(其实也不完全是无界:Integer.MaxValue)?这其实是设计很有意思的一个地方。我们之前已经说过线程池的运行逻辑。如果把阻塞队列设置为无线大,那么在实际线程数量达到corePoolSize之后,再来的线程都会阻塞在这个队列里面。从而保证:根本就没有“短工”。也就限制了线程池的总大小。

第二种:只持有一个线程的线程池,直接把corePoolSize和maximumPoolSize都设置为1,没啥说的

第三种:线程池是无界的。而阻塞队列是一个SynchronousQueue,这个队列的特点是不存放对象的阻塞队列。每一次take必须先于put,换句话说和别的先放再取的队列不一样,这个队列是先“预订”,等一“到货”,立马“交付”。每一个操作都是先做:然后立马阻塞,等别人对应的操作来取,实现几乎直接的交付。

逻辑变成了:因为核心池大小为0,没有长工。放进来的线程先试图进入SynchronousQueue,如果在此之前有worker做完了自己的工作,去SynchronousQueue拿线程(然后被阻塞),就可以实现直接交付给这个空闲的worker执行。如果失败(没有worker是空闲的),那么因为进入失败会直接新建一个worker,进入maximumPool开始执行。而那些执行完自己task都去SynchronousQueue等60秒,如果还有“订单”要来,就开工干活,否者keepAliveTime到被销毁。

时间: 2024-12-28 11:43:23

并发包的线程池第二篇--Executors的构造的相关文章

Java(Android)线程池---基础篇

1.new Thread的弊端 执行一个异步任务你还只是如下new Thread吗? 1 newThread(newRunnable(){ 2 3 @Override 4 publicvoidrun(){ 5 // TODO Auto-generated method stub 6 } 7 }).start(); 那你就out太多了,new Thread的弊端如下: a. 每次new Thread新建对象性能差.b. 线程缺乏统一管理,可能无限制新建线程,相互之间竞争,及可能占用过多系统资源导致

JAVA并发包之线程池ThreadPoolExecutor

学习这个很长时间了一直没有去做个总结,现在大致总结一下并发包的线程池. 首先,任何代码都是解决问题的,线程池解决什么问题? 如果我们不用线程池,每次需要跑一个线程的时候自己new一个,会导致几个问题: 1,不好统一管理线程和它们的相互之间的依赖关系,尤其是有的程序要做的事情很多的时候,线程的处理就显得很杂乱,更雪上加霜的是,线程本身就是不可预期的,不是说先跑的线程就一直在后跑的线程前面,一旦形成复杂的依赖关系,也就会形成复杂的状态(由所有线程的状态共同决定). 2,效率低下,有可能你的每次跑的线

Android多线程编程之线程池学习篇(一)

Android多线程编程之线程池学习篇(一) 一.前言 Android应用开发中多线程编程应用比较广泛,而应用比较多的是ThreadPoolExecutor,AsyncTask,IntentService,HandlerThread,AsyncTaskLoader等,为了更详细的分析每一种实现方式,将单独成篇分析.后续篇章中可能涉及到线程池的知识,特此本篇分析为何使用线程池,如何使用线程池以及线程池的使用原理. 二.Thread Pool基础 进程代表一个运行中的程序,一个运行中的Android

Java并发包下锁学习第二篇Java并发基础框架-队列同步器介绍

Java并发包下锁学习第二篇队列同步器 还记得在第一篇文章中,讲到的locks包下的类结果图吗?如下图: ? 从图中,我们可以看到AbstractQueuedSynchronizer这个类很重要(在本文中,凯哥就用AQS来代替这个类).我们先来了解这个类.对这个类了解之后,学习后面的会更容易了. 本篇是<凯哥(凯哥Java:kagejava)并发编程学习>系列之<Lock系列>教程的第一篇:<Java并发包下锁学习第二篇:队列同步器>. 本文主要内容:同步器介绍:同步器

线程池不使用 Executors 去创建,而是通过 ThreadPoolExecutor 的方式

线程池不使用 Executors 去创建,而是通过 ThreadPoolExecutor 的方式,这样的处理方式让写的同学更加明确线程池的运行规则,规避资源耗尽的风险.说明: Executors 返回的线程池对象的弊端如下:1) FixedThreadPool 和 SingleThreadPool :允许的请求队列长度为 Integer.MAX_VALUE ,可能会堆积大量的请求,从而导致 OOM .2) CachedThreadPool 和 ScheduledThreadPool :允许的创建

Java 并发包之线程池综述

■ 线程池的创建 在Java中,您可以通过调整-Xss参数来调节每个线程栈的大小(64bit系统默认1024KB),当减小该值时意味着可以创建更多的线程数,但问题是JVM资源是有限的,线程不能无限创建! 从笔者开发经验来看,线程池应该是并发包中使用频率和运用场景最多的并发框架,几乎所有并发/异步执行任务的需求都需要用到线程池,线程复用,以内部线程池的形式对外提供管理任务执行,线程调度,线程池管理等等服务.合理的使用线程池可以带来如下三个好处:       1.降低资源消耗:通过重用已创建的线程来

线程池ThreadPoolExecutor、Executors参数详解与源代码分析

欢迎探讨,如有错误敬请指正 如需转载,请注明出处 http://www.cnblogs.com/nullzx/ 1. ThreadPoolExecutor数据成员 Private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING,0)); ctl主要用于存储线程池的工作状态以及池中正在运行的线程数.显然要在一个整型变量存储两个数据,只能将其一分为二.其中高3bit用于存储线程池的状态,低位的29bit用于存储正在运行的线程数. 线

线程池基础篇

一.什么是线程池?为什么要用线程池? 1. 降低资源的消耗.降低线程创建和销毁的资源消耗: 2. 提高响应速度:线程的创建时间为T1,执行时间T2,销毁时间T3,免去T1和T3的时间 3. 提高线程的可管理性. 二.线程池的创建 ThreadPoolExecutor,jdk所有线程池实现的父类 三.参数介绍 先看构造函数: /** * Creates a new {@code ThreadPoolExecutor} with the given initial * parameters. * *

多线程篇六:线程池

1.固定大小的线程池 ExecutorService threadPools1=Executors.newFixedThreadPool(3); for(int i=1;i<=10;i++){ final int task=i; //循环10次,一共往线程池里面放10个任务 threadPools1.execute(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().ge