jdk1.7.0_79
## 在上一篇《ThreadPoolExecutor線程池原理及其execute方法》中提到了在執行緒池ThreadPoolExecutor的原理以及它的execute方法。本文解析ThreadPoolExecutor#submit。
對於一個任務的執行有時我們不需要它回傳結果，但是有我們需要它的回傳執行結果。對於執行緒來講，如果不需要它回傳結果則實作Runnable，而如果需要執行結果的話則可以實作Callable。在執行緒池同樣execute提供一個不需要傳回結果的任務執行，而對於需要結果傳回的則可呼叫其submit方法。
回顧ThreadPoolExecutor的繼承關係。
在Executor介面中只定義了execute方法，而submit方法則是在ExecutorService介面中定義的。
//ExecutorServicepublic interface ExecutorService extends Executor {
...
<T> Future<T> submit(Callable<T> task);
<T> Future<T> submit(Runnable task, T result);
<T> Future<T> submit(Runnable task);
...
}登入後複製
而在其子類別AbstractExecutorService實作了submit方法。
//AbstractExecutorServicepublic abstract class AbstractExecutorService implements ExecutorService {
...
public <T> Future<T> submit(Callable<T> task) {
if (task == null) throw new NullPointerException();
RunnableFuture<T> ftask = newTaskFor(task);
execute(ftask);
return ftask;
}
public <T> Future<T> submit(Runnable task, T result) {
if (task == null) throw new NullPointerException();
RunnableFuture<T> ftask = newTaskFor(task);
execute(ftask);
return ftask;
}
public Future<?> submit(Runnable task) {
if (task == null) throw new NullPointerExeption();
RunnableFuture<Void> ftask = newTaskFor(task, null);
execute(ftask);
return ftask;
}
...
}登入後複製
在AbstractExecutorService實現的submit方法實際上是一個模板方法，定義了submit方法的演算法骨架，其execute交給了子類別。 （可以看到在許多原始碼中，模板方法模式被大量運用，有關模板方法模式可參考《模板方法模式》）
儘管submit方法能提供線程執行的返回值，但只有實現了Callable才會有回傳值，而實作Runnable的執行緒則是沒有回傳值的，也就是說在上面的3個方法中，submit(Callable
task)能取得到它的回傳值，submit(Runnable task, T result)能透過傳入的載體result間接獲得執行緒的回傳值或準確來說交給執行緒處理一下，而最後一個方法submit(Runnable task)則是沒有回傳值的，就算取得它的回傳值也是null 。 以下給3個例子，來感受下submit方法。
submit(Callable task)
package com.threadpoolexecutor;import java.util.concurrent.*;/**
* ThreadPoolExecutor#sumit(Callable<T> task)
* Created by yulinfeng on 6/17/17. */public class Sumit1 {public static void main(String[] args) throws ExecutionException, InterruptedException {
Callable<String> callable = new Callable<String>() {public String call() throws Exception {
System.out.println("This is ThreadPoolExetor#submit(Callable<T> task) method.");return "result";
}
};
ExecutorService executor = Executors.newSingleThreadExecutor();
Future<String> future = executor.submit(callable);
System.out.println(future.get());
}
}登入後複製
# submit(Runnable task,# submit(Runnable task,
#
submit(Runnable task,# submit(Runnable task, T result)
package com.threadpoolexecutor;import java.util.concurrent.ExecutionException;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Future;/**
* ThreadPoolExecutor#submit(Runnable task, T result)
* Created by yulinfeng on 6/17/17. */public class Submit2 {public static void main(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executor = Executors.newSingleThreadExecutor();
Data data = new Data();
Future<Data> future = executor.submit(new Task(data), data);
System.out.println(future.get().getName());
}
}class Data {
String name;public String getName() {return name;
}public void setName(String name) {this.name = name;
}
}class Task implements Runnable {
Data data;public Task(Data data) {this.data = data;
}public void run() {
System.out.println("This is ThreadPoolExetor#submit(Runnable task, T result) method.");
data.setName("kevin");
}
}登入後複製
submit(Runnable task)
#
package com.threadpoolexecutor;import java.util.concurrent.ExecutionException;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Future;/**
* ThreadPoolExecutor#sumit(Runnable runnables)
* Created by yulinfeng on 6/17/17. */public class Submit {public static void main(String[] args) throws ExecutionException, InterruptedException {
Runnable runnable = new Runnable() {public void run() {
System.out.println("This is ThreadPoolExetor#submit(Runnable runnable) method.");
}
};
ExecutorService executor = Executors.newSingleThreadExecutor();
Future future = executor.submit(runnable);
System.out.println(future.get());
}
}登入後複製
透過上面的實例可以看到在呼叫submit(Runnable runnable)的時候是不需要其定義類型的，也就是說雖然在ExecutorService中對其定義的是泛型方法，而在AbstractExecutorService中則不是泛型方法，因為它沒有傳回值。 （有關Object、T、?這三者的區別，可參考《Java中的Object、T（泛型）、?區別》）。
從上面的原始碼可以看到，這三者方法幾乎是一樣的，關鍵就在於：
###RunnableFuture<T> ftask = newTaskFor(task);
execute(ftask);
登入後複製
//AbstractExecutorService#newTaskForprotected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) {
return new FutureTask<T>(callable);
}
protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value) {
return new FutureTask<T>(runnable, value);
}登入後複製
以上是ThreadPoolExecutor執行緒池之submit方法的詳細內容。更多資訊請關注PHP中文網其他相關文章！
