Callable和Future結合使用的一個例子
Callable有返回結果,實現Callable的執行緒被呼叫時會執行實現的call方法-----》Runnable無返回結果,
實現Runnable藉口的執行緒被呼叫時會呼叫run方法實現Callable藉口的執行緒被作為submit方法的傳入引數,
submit方法被執行緒池(在建立該執行緒池的時候會指定有多少個執行緒可以放入執行緒池)呼叫會得到一個返回結果Future<T>,
此處T的型別來自call方法的返回值,就這樣業務方法被放入Callable介面的call方法中執行,
採用執行緒池呼叫即(多執行緒)併發將一次要一個“人”(執行緒),讓多個“人”(執行緒)分開去做,
(前提是我們不急著要一個人全部幹完該活的結果,而且中間還有不同的活要幹)最後再將每個人乾的活彙總檢視最終的結果。
比如下面這段程式碼就是1+2+...+100,我們把他交給10個工人(執行緒去做),
第一個人只需要做1+...+10,
第二個人只需要做11+...+20,
...,
第10個人就計算從90+...+100
最終我們會把每個人計算得到的結果做一個累加
比如第一個人55+第二個人155+...+第10個人的結果955
這樣就求得最終的結果5050
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.List;
import java.util.ArrayList;
import java.util.concurrent.ExecutionException;
class MyCallable implements Callable<Long>{
private Long start;
private Long end;
public MyCallable(Long start, long end){
this.start = start;
this.end = end;
}
public Long call()throws Exception{
long sum = 0;
for(long i = start; i <= end; i++){
sum += i;
}
System.out.println(Thread.currentThread().getName() + " " +start + "-" + end + "=" + sum);
return sum;
}
}
public class CallableAndFuture01{
private static final int NTHREDS = 10;
public static void main(String[] args){
ExecutorService executor = Executors.newFixedThreadPool(NTHREDS);
List<Future<Long>> list = new ArrayList<Future<Long>>();
for(long i=0; i < NTHREDS; i++){
Callable<Long> worker = new MyCallable(i*NTHREDS+1, (i+1)*NTHREDS);
Future<Long> submit = executor.submit(worker);
list.add(submit);
}
long sum = 0;
for(Future<Long> future : list){
try{
sum += future.get();
}catch (InterruptedException e1){
e1.printStackTrace();
}catch(ExecutionException e2){
e2.printStackTrace();
}
}
executor.shutdown();
System.out.println("sum = " + sum);
}
}