线程池

package pool;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class TestThreadPool {
public static void main(String args[]) throws InterruptedException {
// 在线程池中创建2 个线程
ExecutorService exec = Executors.newFixedThreadPool(2);
// 创建100 个线程目标对象
for (int index = 0; index < 100; index++) {
Runnable run = new Runner(index);
// 执行线程目标对象
exec.execute(run);
}
// shutdown
exec.shutdown();
}
}
// 线程目标对象
class Runner implements Runnable {
int index = 0;
public Runner(int index) {
this.index = index;
}
@Override
public void run() {
long time = (long) (Math.random() * 1000);
// 输出线程的名字和使用目标对象及休眠的时间
System.out.println("线程：" + Thread.currentThread().getName() + "(目标对象"
+ index + ")" + ":Sleeping " + time + "ms");

try {
Thread.sleep(time);
} catch (InterruptedException e) {
}
}

}

执行结果的片段如下：
线程：pool-1-thread-1(目标对象23):Sleeping 938ms
线程：pool-1-thread-2(目标对象24):Sleeping 352ms
线程：pool-1-thread-2(目标对象25):Sleeping 875ms
线程：pool-1-thread-1(目标对象26):Sleeping 607ms
线程：pool-1-thread-1(目标对象27):Sleeping 543ms
线程：pool-1-thread-2(目标对象28):Sleeping 520ms
线程：pool-1-thread-1(目标对象29):Sleeping 509ms
线程：pool-1-thread-2(目标对象30):Sleeping 292ms
从执行结果可以看出，线程池中只生成了两个线程对象，100 个线程目标对象共享他们。
从程序中可以看出，使用JDK 提供的线程池一般分为3 步：1）创建线程目标对象，可
以是不同的，例如程序中的Runnner；2）使用Executors 创建线程池，返回一个ExecutorService
类型的对象；3）使用线程池执行线程目标对象，exec.execute(run)，最后，结束线程池中的
线程，exec.shutdown()。