多线程之线程池

线程池的优势和劣势


优势:减少线程的创建和销毁,控制和调整线程的并发数

劣势:需要根据不同的电脑设备配置不同核心线程数,根据业务设置不同的阻塞队列的形式等;一句话:因地制宜,学习起来相对于new thread比较麻烦。

关于疑问


1 thread的创建和销毁占用较多的资源,到底是哪些资源呢?

2 怎么使用线程池就能减少资源消耗?

3 线程池是怎么让线程不被销毁的?


thread 的创建是依托操作系统的,java线程的线程栈是在堆外的,不受虚拟机控制完全受操作系统控制;同时创建和销毁需要内存的申请和回收、列入调度、在cpu进行切换时需要在内存中来回读取信息,这样看thread的使用确实是很复杂且比较重。

使用线程池保证了thread不是频繁的new,有效的控制了thread的数量,在池内有可用线程时不去创建,在没有任务执行时进行相对应的阻塞等一系列手段来减少资源的消耗。

API内的线程池


多线程之Thread 里面提到了thread的执行和工作是不分离的,而线程池的存在就行是把繁杂的工作进行有序的梳理,流程,控制(执行调度和工作单元分开)

ThreadPoolExecutor 通过名称可以知道“线程池执行者”,这个对象就是线程的执行调度者,在它内部有两个函数

execute(Runnable)

submit(Runnable/Callable)

而Runnable Callable 是线程的工作单元,这样DougLea 通过把线程的执行和工作分开,让线程更加工序化(prestartedXX,afterExecute...这一点在Android AsyncTask 的实现中更能说明这一项)

ThreadPoolExecutor是concurrent包下提供的默认实现,文章只分析ThreadPoolExecutor至于Executors里面提供的实现感兴趣的可以自己学习。

打开ThreadPoolExecutor ctrl+o 先笼统的过一遍整体函数,有助于理解的就那么几个函数而已:

1 构造函数

2 addWorker

3 beforeExecute

4 ctlOf

5 execute

6 submit

剩下都是一些get set、shutdown及线程策略(RejectedExecuteHandler的子类) 

备注:也许我个人理解的太简单,但是我自己的学习路线确实是这么做的

构造函数


ThreadPoolExecutor(int corePoolSize,int maxPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,RejectExecuteHandler rejectHandler)

构造函数是重载的,既然是重载的就允许使用者自我定制,且程序内的某些参数会存在默认实现。整个线程池内对于线程的管理创建销毁等都是有以上这些参数共同决定的。

Execute 函数


execute函数内执行了3个if 判断

execute(Runnable command){

    int c =ctl.get();                                            

    if (workerCountOf(c)<corePoolSize){

            if (addWorker(command,true)) return;

                    c =ctl.get();

    }

}

每一次只要有工作单元的对象过来都要调用workerCountOf 和corePoolSize做比较,当小于corePoolSize的时候执行的逻辑都是把“工作单元”的对象添加到works中(HashSet workers = new HashSet()) 并执行对应“工作单元”

addWorker(Runnable task,boolean core){

    Work w = new Work(task);

    Thread t = w.thread;

    xxxx

    works.add(w);

    if(workedAdd)t.start();

}

到这里已经大概清晰了, 调用方创建Runnable “工作单元”,交给Executor 这个“调度者”(ThreadPoolExecutor) 通过execute进行执行(调度者里面有很多控制 工作单元的方法)

execute(Runnable command){

    int c =ctl.get();

    if (isRunning(c) &&workQueue.offer(command)){

        int recheck =ctl.get();

        if (!isRunning(recheck) && remove(command))

            reject(command);

        else if (workerCountOf(recheck) ==0)

            addWorker(null,false);

    }

}

上面的逻辑addWorker(null,falise)是关键,里面只是把 “工作单元”加入到了构造函数的 队列里面 。

截止到目前为止已经解决了文章开头的前两个问题,还剩下最后一个问题"池的线程怎么不销毁的"

在addWorker()函数内,Worker 对象绑定了一个Thread 在调用start 函数时直接触发的是Worker---->run()

run(){

    runWorker(Worker);

}

runWorker(Worker){

    while(task != null || (task == getTask()) != null){xxx}

}

关键点就在于getTask这里

Runnable getTask(){

        Runnable r = timed ?workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) :workQueue.take();

        if (r !=null)

            return r;

}

workQueue 是一个阻塞队列,当队内没有任务时就会阻塞,这里看一个BlockingQueue的实现

public E take()throws InterruptedException {

    final ReentrantLock lock =this.lock;

    lock.lockInterruptibly();

    try {

       while (count ==0)

           notEmpty.await();

        return dequeue();

    }

}

notEmpty.await();这一行就是真正实现阻塞的原因。

到这里文章开头的三个疑问都已经解答了。

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

推荐阅读更多精彩内容