Java併發程式設計——執行緒池的使用（三）執行緒池執行任務、取消任務
阿新 • • 發佈：2019-02-12
一、執行緒池執行Runnable任務
executor.execute(runnable) executor.execute(new Runnable() {
@Override
public void run() {
System.out.println("執行任務");
}
});log:
12-25 11:13:00.260 8710-8860/lbx.myapplication I/System.out: 執行任務二、執行緒池取消任務，shutdown和shutdownNow
執行緒池取消任務的方法有兩種：shutDown()方法和shutDownNow()方法。
2.1 shutdown的使用
先看段程式碼，栗子1：
public static void main(String[] args) { ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, 10, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), new MyThread(), new ThreadPoolExecutor.AbortPolicy()); executor.execute(new Runnable() { @Override public void run() { System.out.println("執行任務"); } }); //呼叫shutdown方法 executor.shutdown(); //再次新增任務 executor.execute(new Runnable() { @Override public void run() { System.out.println("執行任務2"); } }); }
log：
12-25 14:35:20.810 6807-7022/lbx.myapplication I/System.out: 執行任務
Caused by: java.util.concurrent.RejectedExecutionException······
log裡丟擲了異常：RejectedExecutionException，因為我們的拒絕策略是ThreadPoolExecutor.AbortPolicy，執行緒池shutdown後就不可以再新增新任務了。
這裡大家可以再用不同的拒絕策略，自己列印log自己試一下，篇幅有限，我就不在這裡一個一個試了。
栗子2：
public static void main(String[] args) {
ThreadPoolExecutor executor = new ThreadPoolExecutor(
5,
10,
60,
TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(),
new MyThread(),
new ThreadPoolExecutor.AbortPolicy());
for (int i = 0; i < 10; i++) {
final int finalI = i;
executor.execute(new Runnable() {
@Override
public void run() {
try {
System.out.println("第" + finalI);
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
}
try {
Thread.sleep(300);
//在主執行緒呼叫shutdown
executor.shutdown();
System.out.println("已經shutdown了");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
log：
12-25 15:02:19.130 11997-12132/lbx.myapplication I/System.out: 第0
12-25 15:02:19.130 11997-12134/lbx.myapplication I/System.out: 第2
12-25 15:02:19.130 11997-12133/lbx.myapplication I/System.out: 第1
12-25 15:02:19.130 11997-12135/lbx.myapplication I/System.out: 第3
12-25 15:02:19.130 11997-12136/lbx.myapplication I/System.out: 第4
12-25 15:02:19.430 11997-11997/lbx.myapplication I/System.out: 已經shutdown了
12-25 15:02:19.630 11997-12132/lbx.myapplication I/System.out: 第5
12-25 15:02:19.630 11997-12134/lbx.myapplication I/System.out: 第6
12-25 15:02:19.630 11997-12133/lbx.myapplication I/System.out: 第7
12-25 15:02:19.630 11997-12135/lbx.myapplication I/System.out: 第8
12-25 15:02:19.630 11997-12136/lbx.myapplication I/System.out: 第9跟之前的栗子1做對比我們發現，呼叫shutdown只是拒絕向佇列裡新增任務，而已經在佇列裡的任務，扔會繼續執行。
2.2 shutdownNow的使用
栗子3：
繼續用栗子1的程式碼就好，不同的是，把shutdown改成shutdownNow，其他地方不變，所以我就不上程式碼了，log也是一樣的，仍然執行第一個任務，然後丟擲異常RejectedExecutionException。
栗子4：同樣的，繼續用栗子2的程式碼就好，不同的是，把shutdown改成shutdownNow，其他地方不變，執行程式碼，看log：
12-25 15:30:57.560 2251-2424/lbx.myapplication I/System.out: 第0
12-25 15:30:57.560 2251-2425/lbx.myapplication I/System.out: 第1
12-25 15:30:57.560 2251-2426/lbx.myapplication I/System.out: 第2
12-25 15:30:57.560 2251-2428/lbx.myapplication I/System.out: 第4
12-25 15:30:57.570 2251-2427/lbx.myapplication I/System.out: 第3
12-25 15:30:57.860 2251-2251/lbx.myapplication I/System.out: 已經shutdownNow了我們發現，呼叫shutdownNow後，這時執行緒池所執行的任務停止了，當然，新新增任務也是會被拒絕的，所以，shutdownNow會立刻停止所有正在執行的任務，並且佇列不接受新的任務。