并发学习计划-了解Executors创建线程池的部分方法07

终于讲到Executors来了,学习并发这个系列的最初目的也是为了更好的了解Executors这个类的使用方法。

首先说说这个类是干嘛的。

这个类充斥了无数的静态方法,也就是说,这个类里面大部分的方法都是可以直接通过类名调用的,所以很显然这是一个工具类了,先感受下这个工具类


Executors.jpg

new开头的方法就有这么多,这些方法主要都是创建线程池的,但是我并不会讲完所有的new系列的方法,我会将我们熟悉的方法。

什么叫我们熟悉的方法呢,就是只要一看源码,你就什么都知道了的意思。

今天我要讲以下4个方法:


newThreadPool.jpg

上图就是我要讲解的4个方法,截图的目的是为了让大家可以方便的看到方法里面的参数的含义。

注意:图中的参数我是乱填的,纯粹为了简洁,大家不可照着图中的示例参数填写。

我们来学习第一个方法,直接看这个函数的源码,相信你一定能知道这个函数是干嘛的了。

public static ExecutorService newCachedThreadPool() {
        return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                      60L, TimeUnit.SECONDS,
                                      new SynchronousQueue<Runnable>());
    }

LOOK!里面居然用到了ThreadPoolExecutor,还记得我在这篇文章《通俗理解ThreadPoolExecutor》中讲过ThreadPoolExecutor吗,没看过这篇文章的赶紧去速读一篇,不然下面我讲的东西你会觉得莫名其妙。

用到了ThreadPoolExecutor,我们看看源码中是怎么填写参数的,0、MAX、60L、SECONDS、SynchronousQueue,队列居然用的是SynchronousQueue同步队列,我在这篇文章《SynchronousQueue》中讲过同步队列,没看过的也去看看,文章很短。要不了一分钟就可以看完。

我们来根据这些参数来套超市的例子。

那这个方法就是这样的:
超市有Integer.MAX_VALUE个收银台,最开始没有收银员,排队也只允许排一个,收银员闲置时间超过60秒,就会离开。

所以这其实可以容纳无限的任务,指定了运行收银台的数量,永远不会出现任务溢出的情况

这个方法说清楚了,newCachedThreadPool(ThreadFactory threadFactory)这个方法也就不必说了,无非就是自定义如何创建线程。

现在来看看这个方法

public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                0L, TimeUnit.MILLISECONDS,
                new LinkedBlockingQueue<Runnable>());
    }

看看这个队列,现在换成了LinkedBlockingQueue,而且也没有指定容量大小,所以这个队列可以容下无数的顾客,也就是容量变成了虚拟机内存大小了。

然后参数指定了有多少个收银员和收银台,那就永远不会出现任务溢出的情况了。

newFixedThreadPool(int nThreads, ThreadFactory threadFactory)这个方法也就没有必要讲了吧。

到此这4个方法就算讲完了,其他的使用方式也就没有必要讲了。

不过为了负责,这里还是贴一下文档的话:

newCachedThreadPool()
创建一个可根据需要创建新线程的线程池,但是在以前构造的线程可用时将重用它们。

newCachedThreadPool(ThreadFactory threadFactory)
创建一个可根据需要创建新线程的线程池,但是在以前构造的线程可用时将重用它们,并在需要时使用提供的 ThreadFactory 创建新线程。

newFixedThreadPool(int nThreads)
创建一个可重用固定线程数的线程池,以共享的无界队列方式来运行这些线程。

newFixedThreadPool(int nThreads, ThreadFactory threadFactory)`
创建一个可重用固定线程数的线程池,以共享的无界队列方式来运行这些线程,在需要时使用提供的 ThreadFactory 创建新线程

最后在加一点友情提示,在阿里巴巴Java开发手册中,并不推荐直接使用Executors,原文如下:

线程池不允许使用 Executors 去创建,而是通过 ThreadPoolExecutor 的方式,这样
的处理方式让写的同学更加明确线程池的运行规则,规避资源耗尽的风险。 说明:Executors 返回的线程池对象的弊端如下:

  1. FixedThreadPool 和 SingleThreadPool:
    允许的请求队列长度为 Integer.MAX_VALUE,可能会堆积大量的请求,从而导致 OOM。
  2. CachedThreadPool 和 ScheduledThreadPool:
    允许的创建线程数量为 Integer.MAX_VALUE,可能会创建大量的线程,从而导致 OOM。
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 205,033评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,725评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,473评论 0 338
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,846评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,848评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,691评论 1 282
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,053评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,700评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 42,856评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,676评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,787评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,430评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,034评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,990评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,218评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,174评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,526评论 2 343

推荐阅读更多精彩内容