学步园

IT程序员开发必备-各类资源下载清单，史上最全IT资源，个人收藏总结！

1.线程池的概念与Executors类的应用
    (1)创建固定大小的线程池
    (2)创建缓存线程池
    (3)创建单一线程池
  2.关闭线程池
    (1)shutdown与shutdownNow的比较
  3.用线程池启动定时器
    (1)调用ScheduledExecutorService的schedule方法，返回的ScheduleFuture对象可以取消任务。
    (2)支持间隔重复任务的定时方式，不直接支持绝对定时方式，需要转换成相对时间方式。

例子程序:

package edu.java5.threadpool;

import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ThreadPool {
	public static void main(String[] args) {
		
		//创建一个有三个线程的线程池
		//ExecutorService threadPool = Executors.newFixedThreadPool(3);
		//线程池中的线程数是不定的，任务来了，线程池服务不过来，就创建线程，服务完毕则多的线程销毁
		//ExecutorService threadPool = Executors.newCachedThreadPool();
		//单一线程池
		ExecutorService threadPool = Executors.newSingleThreadExecutor();
		//为该线程池分配10个任务
		for (int i = 0; i < 10; i++) {
			final int task = i;
			threadPool.execute(new Runnable() {
				@Override
				public void run() {
					//每次任务是个5次循环
					for (int j = 0; j < 5; j++) {
						try {
							Thread.sleep(new Random().nextInt(100));
						} catch (InterruptedException e) {
							e.printStackTrace();
						}
						System.out.println(Thread.currentThread().getName()+" is looping of "+j+"  for task of "+task);
					}
				}
			});
		}
		System.out.println("10个任务全部完成！");
		threadPool.shutdown();//执行此代码，则线程池在完成全部任务后，会释放线程池的线程
		//threadPool.shutdownNow();//执行此代码，则线程池立即关闭。返回的是没有执行的任务集合List<Runnable>
        
	   /**
	    * 用线程池启动定时器
            *    1.调用ScheduledExecutorService的schedule方法，返回的ScheduleFuture对象可以取消任务。
            *    2.支持间隔重复任务的定时方式，不直接支持绝对定时方式，需要转换成相对时间方式。 
	    **/
	     //延迟5秒后，由线程池分配线程执行任务
		Executors.newScheduledThreadPool(3).schedule(new Runnable() {
			@Override
			public void run() {
				System.out.println(Thread.currentThread().getName()+" scheduled the task after 5 seconds");
			}
		}, 5, TimeUnit.SECONDS);
	    //延迟5秒后,以固定频率调用任务
		Executors.newScheduledThreadPool(3).scheduleAtFixedRate(new Runnable() {
			@Override
			public void run() {
				System.out.println(Thread.currentThread().getName()+" scheduled the task after 5 seconds and at fixed rate");
			}
		}, 5,3, TimeUnit.SECONDS);

           //那么对于在固定时间由线程池分配线程执行任务，java5中没有特定的方法，我们可以通过(task,date.getTime()-System.currentTimeMillis(),TimeUnit.MILLISECONDS)
	}
}