《转载》 ThreadPool shutdown 与shutdownNow

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
package com.other.Thread;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.RejectedExecutionException;

public class ThreadPoolTest {

	ExecutorService executor;

	public static void main(String[] args) {
		ThreadPoolTest threadInterupttest = new ThreadPoolTest();
		threadInterupttest.executor = Executors.newSingleThreadExecutor();

		for (int i = 1; i <= 5; i++) {
			try {
				threadInterupttest.executor.execute(threadInterupttest.new MyRunnable(i));
			} catch (RejectedExecutionException e) {
				System.out.println(e.getMessage() + "    " + i);
			}

			if (i == 4) {
				threadInterupttest.executor.shutdownNow();
			}
		}
	}

	class MyRunnable implements Runnable {

		public int i;
		public MyRunnable(int i) {
			this.i = i;
		}

		@Override
		public void run() {
			// int a = 0;
			// for (double m = 0; m < Integer.MAX_VALUE; m++) {
			// a++;
			// }

			try {
				Thread.sleep(2000);
			} catch (InterruptedException e) {
				System.out.println(e.getMessage() + "          " + i);
			}

			System.out.println("I am the " + i + " task");
		}
	}
	
	
}

1
2
3
4
sleep interrupted          1
I am the 1 task
null    5

1
2
3
4
5
6
null    5
I am the 1 task
I am the 2 task
I am the 3 task
I am the 4 task