本文共 3651 字，大约阅读时间需要 12 分钟。

Executor框架

为了更好的控制多线程，JDK提供了一套线程框架Executor，帮助开发人员有效进行线程控制。他们都在java.util.concurrent包中，是JDK并发包的核心。其中有一个比较重要的类Executors,他扮演线程工厂的角色，我们通过Executors可以创建特定功能的线程池，Executors创建线程池的方法：

• newFixedThreadPool()：
  该方法返回一个固定数量的线程池，该方法的线程数始终不变，当有一个任务提交时，若线程池中空闲，则立即执行，若没有，则会被暂缓在一个任务队列中等待有空闲的线程去执行。
• newSingleThreadExecutor()：
  创建一个线程的线程池，若空闲则执行，若没有空闲线程则暂缓在任务队列中。
• newCachedThreadPool()：
  返回一个可根据实际情况调整线程个数的线程池，不限制最大线程数量，若有空闲的线程则执行任务，若无任务则不创建线程。并且每一个空闲线程会在60s后自动回收。
• newScheduledThreadPool()：
  该方法返回一个ScheduledExecutorService对象，该线程池可以指定线程数量。

public class Temp extends Thread {	public void run(){		System.out.println("run");	}	public static void main(String[] args) {		Temp command = new Temp();		ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);				//表示command这个任务在初始化时延迟1s钟并且每隔3s钟轮询command的run方法		ScheduledFuture
    scheduleTask = scheduler.scheduleWithFixedDelay(command, 1, 3, TimeUnit.SECONDS);	}}

自定义线程池

若Executors工厂类无法满足我们的需求，可以自己去取创建自定义线程池，其实Executors工厂类里面的创建线程方法其内部实现均是使用了ThreadPoolExecutor这个类，这个类可以自定义线程池。构造方法如下：

public ThreadPoolExector(int corePoolSize,//核心线程数，即初始化时有多少个线程                         int maximumPoolSize,//最大线程数                         long keepAliveTime,//线程池中每一个线程的空闲时间                         TimeUnit unit,//线程空闲时间单位                         BlockingQueue
   
     workQueue,//当线程池已满时其他线程存放的队列                         ThreadFactory threadFactory,                         RejectedExecutionHandler handler//队列已满时的拒绝策略){...}
   

自定义线程池使用说明

ThreadPoolExector构造方法对于队列是什么类型比较关键：

• 有界队列：
  若有新的任务需要执行，如果线程池实际线程数小于corePoolSize，则优先创建线程，若大于corePoolSize，则会将任务加入到队列中，若队列已满，则在总线程数不大于maximumPoolSize的前提下，创建新的线程，若线程数大于maximumPoolSize，则执行拒绝策略。或其他自定义方式。
• 无界队列：
  LinkedBlockingQueue，与有界队列相比，除非系统资源耗尽，否则无界队列的任务队列不存在任务入队失败的情况。当有新的任务到来，系统的线程数小于corePoolSize时，则新建线程执行任务。当达到corePoolSize后，就不会继续增加。若后续仍有新的任务加入，而没有空闲的线程资源，则任务直接进入队列等待。若任务创建和处理的速度差异很大，无界队列会保持快速增长，直到系统内存耗尽。

JDK拒绝策略：

• AbortPolicy：直接抛出异常组织系统正常工作。
• CallRunsPolicy：只要线程池未关闭，该策略直接在调用者线程中，运行当前被丢弃的任务。
• DiscardOldestPolicy：丢弃最老的请求，尝试再次提交当前任务。
• DiscardPolicy：丢弃无法处理的任务，不给于任何处理。

如果需要自定义拒绝策略可以实现RejectedExecutionHandler接口。

public class UseThreadPoolExecutor1 {	public static void main(String[] args) {		ThreadPoolExecutor pool = new ThreadPoolExecutor(				1, //coreSize				2, //MaxSize				60,//60				TimeUnit.SECONDS,				new ArrayBlockingQueue
   
    (3),//指定有界队列				new MyRejected());//自定义拒绝策略		MyTask mt1 = new MyTask(1, "任务1");		MyTask mt2 = new MyTask(2, "任务2");		MyTask mt3 = new MyTask(3, "任务3");		MyTask mt4 = new MyTask(4, "任务4");		MyTask mt5 = new MyTask(5, "任务5");		MyTask mt6 = new MyTask(6, "任务6");				pool.execute(mt1);		pool.execute(mt2);		pool.execute(mt3);		pool.execute(mt4);		pool.execute(mt5);		pool.execute(mt6);				pool.shutdown();	}}
   

public class MyTask implements Runnable {	private int id;		private String name;		public MyTask(int id, String name){		this.id = id;		this.name = name;	}		public int getId() {		return id;	}	public void setId(int id) {		this.id = id;	}	public String getName() {		return name;	}	public void setName(String name) {		this.name = name;	}	@Override	public void run() {		try {			System.out.println("run taskId = " + this.getId());			Thread.sleep(5*1000);		} catch (InterruptedException e) {			e.printStackTrace();		}	}	@Override	public String toString() {		return this.getId() + " : " + this.getName();	}}

public class MyRejected implements RejectedExecutionHandler {	/**	 * @param paramRunnable 当前任务对象	 * @param paramThreadPoolExecutor 当前线程池对象	 * */	@Override	public void rejectedExecution(Runnable paramRunnable, ThreadPoolExecutor paramThreadPoolExecutor) {		System.out.println("自定义拒绝策略...");		System.out.println("当前被拒绝的任务为：" + paramRunnable.toString());	}}

转载地址：http://jbkni.baihongyu.com/