我已經向ExecutorService提交了兩項任務task1
& task2
。任務2需要5秒才能完成,而任務1需要10秒。如何取消ExecutorService上的不完整任務
當task2完成並繼續邏輯的其餘部分時,如何停止提交的任務(即:task1)?
這裏是我到目前爲止的代碼:
public class mt_poc {
public static void action_1() throws InterruptedException {
System.out.println("action_1 invoke ");
Thread.sleep(10000);
action_2();
System.out.println("action_1 done");
}
public static void action_2() throws InterruptedException {
System.out.println("action_2 invoke ");
Thread.sleep(5000);
System.out.println("action_2 done ");
}
public static void main(String[] args) {
System.out.println("TEST");
Runnable task1 = new Runnable() {
public void run() {
try {
action_1();
}
catch(InterruptedException e) {
System.out.println("action_1 invoke interrupted");
}
System.out.println("action_1 invoke run is over");
}
};
Runnable task2 = new Runnable() {
public void run() {
try {
action_2();
}
catch(InterruptedException e) {
System.out.println("action_2 invoke interrupted");
}
System.out.println("action_2 invoke run is over");
}
};
ExecutorService executor = Executors.newFixedThreadPool(2);
try {
executor.submit(task1);
executor.submit(task2);
// cancel uncomplete task
executor.shutdown();
executor.awaitTermination(5, TimeUnit.SECONDS);
// continues the rest of logic
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Shutdown executor");
}
}