线程池newFixedThreadPool的使用

新的线程加入后，如果正在运行的线程达到了上限，则会阻塞，直到有了空闲的线程来运行。

1. import java.util.Random;
2. import java.util.concurrent.ExecutorService;
3. import java.util.concurrent.Executors;
4. import java.util.concurrent.TimeUnit;
6. /**
7.  * 线程池newFixedThreadPool的使用。
8.  * 
9.  * @author 赵学庆，Java世纪网(java2000.net)
10.  * 
11.  */
12. public class ExecutorTest {
13.   public static void main(String args[]) {
14.     Random random = new Random();
15.     // 建立一个容量为3的固定尺寸的线程池
16.     ExecutorService executor = Executors.newFixedThreadPool(3);
17.     // 判断可是线程池可以结束
18.     int waitTime = 500;
19.     for (int i = 0; i < 10; i++) {
20.       String name = "线程 " + i;
21.       int time = random.nextInt(1000);
22.       waitTime += time;
23.       Runnable runner = new ExecutorThread(name, time);
24.       System.out.println("增加: " + name + " / " + time);
25.       executor.execute(runner);
26.     }
27.     try {
28.       Thread.sleep(waitTime);
29.       executor.shutdown();
30.       executor.awaitTermination(waitTime, TimeUnit.MILLISECONDS);
31.     } catch (InterruptedException ignored) {
32.     }
33.   }
34. }
36. class ExecutorThread implements Runnable {
37.   private final String name;
38.   private final int delay;
40.   public ExecutorThread(String name, int delay) {
41.     this.name = name;
42.     this.delay = delay;
43.   }
45.   public void run() {
47.     System.out.println("启动: " + name);
48.     try {
49.       Thread.sleep(delay);
50.     } catch (InterruptedException ignored) {
51.     }
52.     System.out.println("完成: " + name);
53.   }
54. }