1. 程式人生 > >Callable和Future結合使用的一個例子

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);
 }
}