java.util.concurrent下线程池总结(1)

首先,看下总的结构:

 

---

Executors类，提供了一系列工厂方法用于创先线程池，返回的线程池都实现了ExecutorService接口。

public static ExecutorService newFixedThreadPool(int nThreads)

创建固定数目线程的线程池。

public static ExecutorService newCachedThreadPool()

创建一个可缓存的线程池，调用execute 将重用以前构造的线程（如果线程可用）。

如果现有线程没有可用的，则创建一个新线程并添加到池中。终止并从缓存中移除那些已有 60 秒钟未被使用的线程。

public static ExecutorService newSingleThreadExecutor()

创建一个单线程化的Executor。

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)

创建一个支持定时及周期性的任务执行的线程池，多数情况下可用来替代Timer类。

---

public class Executors_1 extends Thread {
	String name ;
	public Executors_1(String name) {
		super(name);
		this.name = name;
	}
	@Override
	public void run() {
		int i = 0;
		while(i < 3){
			System.out.println(name + " run :" + i);
			i++;
		}
	}
	public static void main(String[] args) throws Exception {
		ExecutorService es = Executors.newFixedThreadPool(1);
		for(int i = 0; i < 4; i++){
			es.execute(new Executors_1(String.valueOf(i)));
		}
		TimeUnit.SECONDS.sleep(4L);
		es.shutdown();
		
		ScheduledExecutorService ses = Executors.newScheduledThreadPool(1);
		ScheduledFuture<?> sf =	ses.scheduleAtFixedRate(new Executors_1(String.valueOf("scheduler")),
					10 , 10, TimeUnit.SECONDS); // 延迟10秒运行,每10秒运行一次
		TimeUnit.SECONDS.sleep(30L);
		sf.cancel(true); // 中断sf
	}
}