java.util.concurrent 之一

package test;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class TestThreadPool {
	public static void main(String args[]) throws InterruptedException{
	// only two threads
	ExecutorService exec = Executors.newFixedThreadPool(2);
	for(int index=0; index < 10; index++){
		Runnable run = new Runnable(){
			public void run(){
				long time = (long)(Math.random() * 1000);
				System.out.println("Sleeping " + time + "ms");
				try{
					Thread.sleep(time);
				}	catch(InterruptedException e){
				}
			}
		};
		exec.execute(run);
	}	// must shutdown
	exec.shutdown();
}
	}

可能的运行结果：

Sleeping 543ms
Sleeping 33ms
Sleeping 658ms
Sleeping 740ms
Sleeping 145ms
Sleeping 216ms
Sleeping 890ms
Sleeping 864ms
Sleeping 786ms
Sleeping 644ms

上面是一个简单的例子。使用大小为2的线程池来处理10个线程。

它使用了Executors的静态函数 newFixedThreadPool() 生成一个固定的线程池。顾名思义，

线程池是不会释放的，即使它是Idle。这就会产生性能问题。比如如果线程池的大小为200，当全部使用完毕后，

所有的线程会继续留在池中，相应的内存和线程切换（while(true)+sleep）都会增加。如果要避免这个问题，就

必须直接使用ThreadPoolExecutor()来构造。可以像Tomcat的线程池一样，设置“最大线程数”、“最小线程数”

和“空闲线程keepAlive的时间”。通过这些可以基本上替换Tomcat的线程池实现方案。

需要注意的是线程池必须使用shutdown来显式关闭，否则主线程就无法退出。