jdk1.7.0_79
網(wǎng)站建設(shè)哪家好，找創(chuàng)新互聯(lián)！專注于網(wǎng)頁設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、微信小程序開發(fā)、集團(tuán)企業(yè)網(wǎng)站建設(shè)等服務(wù)項(xiàng)目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了清苑免費(fèi)建站歡迎大家使用！
在上一篇《ThreadPoolExecutor線程池原理及其execute方法》中提到了線程池ThreadPoolExecutor的原理以及它的execute方法。本文解析ThreadPoolExecutor#submit。
對(duì)于一個(gè)任務(wù)的執(zhí)行有時(shí)我們不需要它返回結(jié)果，但是有我們需要它的返回執(zhí)行結(jié)果。對(duì)于線程來講，如果不需要它返回結(jié)果則實(shí)現(xiàn)Runnable，而如果需要執(zhí)行結(jié)果的話則可以實(shí)現(xiàn)Callable。在線程池同樣execute提供一個(gè)不需要返回結(jié)果的任務(wù)執(zhí)行，而對(duì)于需要結(jié)果返回的則可調(diào)用其submit方法。
回顧ThreadPoolExecutor的繼承關(guān)系。
在Executor接口中只定義了execute方法，而submit方法則是在ExecutorService接口中定義的。
重慶分公司
重慶分公司
//ExecutorService
public interface ExecutorService extends Executor {
...
Future submit(Callable task);
Future submit(Runnable task, T result);
Future submit(Runnable task);
...
} 而在其子類AbstractExecutorService實(shí)現(xiàn)了submit方法。
//AbstractExecutorService
public abstract class AbstractExecutorService implements ExecutorService {
...
public Future submit(Callable task) {
if (task == null) throw new NullPointerException();
RunnableFuture ftask = newTaskFor(task);
execute(ftask);
return ftask;
}
public Future submit(Runnable task, T result) {
if (task == null) throw new NullPointerException();
RunnableFuture ftask = newTaskFor(task);
execute(ftask);
return ftask;
}
public Future<?> submit(Runnable task) {
if (task == null) throw new NullPointerExeption();
RunnableFuture ftask = newTaskFor(task, null);
execute(ftask);
return ftask;
}
...
} 在AbstractExecutorService實(shí)現(xiàn)的submit方法實(shí)際上是一個(gè)模板方法，定義了submit方法的算法骨架，其execute交給了子類。（可以看到在很多源碼中，模板方法模式被大量運(yùn)用，有關(guān)模板方法模式可參考《模板方法模式》）
盡管submit方法能提供線程執(zhí)行的返回值，但只有實(shí)現(xiàn)了Callable才會(huì)有返回值，而實(shí)現(xiàn)Runnable的線程則是沒有返回值的，也就是說在上面的3個(gè)方法中，submit(Callable
下面給出3個(gè)例子，來感受下submit方法。
submit(Callable
package com.threadpoolexecutor; import java.util.concurrent.*; /** * ThreadPoolExecutor#sumit(Callabletask) * Created by yulinfeng on 6/17/17. */ public class Sumit1 { public static void main(String[] args) throws ExecutionException, InterruptedException { Callable callable = new Callable () { public String call() throws Exception { System.out.println("This is ThreadPoolExetor#submit(Callable task) method."); return "result"; } }; ExecutorService executor = Executors.newSingleThreadExecutor(); Future future = executor.submit(callable); System.out.println(future.get()); } }
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 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());
}
}通過上面的實(shí)例可以看到在調(diào)用submit(Runnable runnable)的時(shí)候是不需要其定義類型的，也就是說雖然在ExecutorService中對(duì)其定義的是泛型方法，而在AbstractExecutorService中則不是泛型方法，因?yàn)樗鼪]有返回值。（有關(guān)Object、T、?這三者的區(qū)別，可參考《Java中的Object、T（泛型）、?區(qū)別》）。
從上面的源碼可以看到，這三者方法幾乎是一樣的，關(guān)鍵就在于：
RunnableFutureftask = newTaskFor(task); execute(ftask);
它是如何將一個(gè)任務(wù)作為參數(shù)傳遞給了newTaskFor，然后調(diào)用execute方法，最后進(jìn)而返回ftask的呢？
//AbstractExecutorService#newTaskFor protectedRunnableFuture newTaskFor(Callable callable) { return new FutureTask (callable); } protected RunnableFuture newTaskFor(Runnable runnable, T value) { return new FutureTask (runnable, value); }
看來是返回了一個(gè)FutureTask實(shí)例，F(xiàn)utureTask實(shí)現(xiàn)了Future和Runnable接口。Future接口是Java線程Future模式的實(shí)現(xiàn)，可用用來異步計(jì)算，實(shí)現(xiàn)Runnable接口表示可以作為一個(gè)線程執(zhí)行。FutureTask實(shí)現(xiàn)了這兩個(gè)接口意味著它代表異步計(jì)算的結(jié)果，同時(shí)可以作為一個(gè)線程交給Executor來執(zhí)行。有關(guān)FutureTask放到下章來單獨(dú)解析。所以本文對(duì)于線程池ThreadPoolExecutor線程池的submit方法解析并不完整，必須得了解Java線程的Future模式——《老生常談Java中的Future模式》。
以上這篇簡單談?wù)凾hreadPoolExecutor線程池之submit方法就是小編分享給大家的全部內(nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持創(chuàng)新互聯(lián)。
