A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© wangning9130 中级黑马   /  2013-12-20 21:51  /  1366 人查看  /  2 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

最近看张老师的视频,有很多次都用到了线程池,但是又没讲太多。
所以,自己的理解也不是那么透彻,那么,能不能有几位大神来细致的解读一下,
jdk1.5的线程池,我只知道有一个类Executors,他提供静态方法来操作各种线程池。
但是具体原理不是怎么了解。有劳各位!!

评分

参与人数 1技术分 +1 收起 理由
乔兵 + 1

查看全部评分

2 个回复

倒序浏览

关于线程池研究及例子(下面比较详细,你可以参考看看)
一、API研究线程池类为 java.util.concurrent.ThreadPoolExecutor,常用构造方法为:Java代码  

  • ThreadPoolExecutor(int corePoolSize,   
  •                    int maximumPoolSize,   
  •                    long keepAliveTime, TimeUnit unit,   
  •                    BlockingQueue<Runnable> workQueue,   
  •                    RejectedExecutionHandler handler)  

  • corePoolSize
    线程池维护线程的最少数量
  • maximumPoolSiz
    线程池维护线程的最大数量
  • keepAliveTime
    线程池维护线程所允许的空闲时间
  • unit
    线程池维护线程所允许的空闲时间的单位
  • workQueue
    线程池所使用的缓冲队列
  • handler
    线程池对拒绝任务的处理策略
一个任务通过 execute(Runnable)方法被添加到线程池,任务就是一个 Runnable类型的对象,任务的执行方法就是 Runnable类型对象的run()方法。

当一个任务通过execute(Runnable)方法欲添加到线程池时:
  • 如果此时线程池中的数量小于corePoolSize,即使线程池中的线程都处于空闲状态,也要创建新的线程来处理被添加的任务。
  • 如果此时线程池中的数量等于 corePoolSize,但是缓冲队列 workQueue未满,那么任务被放入缓冲队列。
  • 如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量小于maximumPoolSize,建新的线程来处理被添加的任务。
  • 如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量等于maximumPoolSize,那么通过 handler所指定的策略来处理此任务。
也就是:处理任务的优先级为:
核心线程corePoolSize、任务队列workQueue、最大线程maximumPoolSize,如果三者都满了,使用handler处理被拒绝的任务。

当线程池中的线程数量大于 corePoolSize时,如果某线程空闲时间超过keepAliveTime,线程将被终止。这样,线程池可以动态的调整池中的线程数。

unit可选的参数为java.util.concurrent.TimeUnit中的几个静态属性:
NANOSECONDS、MICROSECONDS、MILLISECONDS、SECONDS。

workQueue我常用的是:java.util.concurrent.ArrayBlockingQueue

handler有四个选择:
  • ThreadPoolExecutor.AbortPolicy()
    抛出java.util.concurrent.RejectedExecutionException异常
  • ThreadPoolExecutor.CallerRunsPolicy()
    由调用者执行这个任务
  • ThreadPoolExecutor.DiscardOldestPolicy()
    抛弃旧的任务
  • ThreadPoolExecutor.DiscardPolicy()
    抛弃当前的任务
二、一般用法举例     TestTheadPool主类:Java代码  

  • package com.ibm.threadpool;  
  •   
  • import java.util.concurrent.ArrayBlockingQueue;  
  • import java.util.concurrent.ThreadPoolExecutor;  
  • import java.util.concurrent.TimeUnit;  
  •   
  • public class TestThreadPool {  
  •     private static int produceTaskSleepTime = 2000;  
  •   
  •     public static void main(String[] args) {  
  •         // 构造一个线程池  
  •         ThreadPoolExecutor producerPool = new ThreadPoolExecutor(2, 4, 0,  
  •                 TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(3),  
  •                 new ThreadPoolExecutor.DiscardOldestPolicy());  
  •   
  •         // 每隔produceTaskSleepTime的时间向线程池派送一个任务。  
  •         int i = 1;  
  •         while (true) {  
  •             try {  
  •                 Thread.sleep(produceTaskSleepTime);  
  •   
  •                 String task = "task@ " + i;  
  •                 System.out.println("put " + task);  
  •   
  •                 producerPool.execute(new ThreadPoolTask(task));  
  •   
  •                 i++;  
  •             } catch (Exception e) {  
  •                 e.printStackTrace();  
  •             }  
  •         }  
  •     }  
  •   
  • }  

Task:Java代码  

  • package com.ibm.threadpool;  
  • import java.io.Serializable;  
  •   
  • /**
  • * 线程池执行的任务
  • */  
  • public class ThreadPoolTask implements Runnable, Serializable {  
  •   
  •     /**
  •      * serialVersionUID, JDK1.5中,每个实现Serializable接口的类都推荐声明这样的一个ID
  •      */  
  •     private static final long serialVersionUID = -2443443826296885045L;  
  •   
  •   
  •     private static int consumeTaskSleepTime = 2000;  
  •   
  •     private Object threadPoolTaskData;  
  •   
  •     ThreadPoolTask(Object tasks) {  
  •         this.threadPoolTaskData = tasks;  
  •     }  
  •   
  •     // 每个任务的执行过程,现在是什么都没做,除了print和sleep,:)  
  •     public void run() {  
  •         System.out.println("start .." + threadPoolTaskData);  
  •         try {  
  •             // 便于观察现象,等待一段时间  
  •             Thread.sleep(consumeTaskSleepTime);  
  •         } catch (Exception e) {  
  •             e.printStackTrace();  
  •         }  
  •         threadPoolTaskData = null;  
  •     }  
  •   
  • }  


评分

参与人数 1技术分 +1 收起 理由
乔兵 + 1

查看全部评分

回复 使用道具 举报
官网有套视频叫  张孝祥_Java多线程与并发库高级应用
传说中的高新技术续集,我就看了2集还没看完。
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马