java多線程Future和Callable類示例分享

java多線程Future和Callable類示例分享。本站提示廣大學習愛好者：（java多線程Future和Callable類示例分享）文章只能為提供參考，不一定能成為您想要的結果。以下是java多線程Future和Callable類示例分享正文

一，描述論述

    ​在多線程下編程的時刻。年夜家能夠會碰到一種需求，就是我想在我開啟的線程都停止時，統一時刻獲得每個線程中前往的數據然後再做同一處置，在這類需求下，Future與Callable的組合就派上了異常年夜的用處。

也有人會說，我可以或許應用同步來終了這個需求啊，通俗情形下確切可以或許。可是在一種特別情形下就不可了：

    ​想象，你開啟了多個線程同步盤算一些數據，可是年夜家都曉得，線程是會爭用資本的，也就是說。你開啟多個線程來同步盤算數據時。現實上線程之間的盤算次序是弗成空的，固然除非你非異常年夜周折行止理也不無能夠。在如許的情形下。Future和Callable的組合就是不貳之選了。

二，樣例

這兩個類的樣例現實上異常easy，重要就看本身在現實應用中能不克不及找到他們的用武之地了。上代碼：

package test;
 
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
 
public class FetureCallableTest {
  private static ExecutorService service = Executors.newFixedThreadPool(100);
  private static int count = 1;
  public static void main(String[] args) throws InterruptedException, ExecutionException {
    int sum = 0;
    for(int i = 0; i < 100; i++) {
      Future<Integer> future = service.submit(new Callable<Integer>(){
   
        @Override
        public Integer call() throws Exception {
          System.out.println(Thread.currentThread().getName());
          return ++count;
        }
         
      });
      int f = future.get();
      sum += f;
      System.out.println("future is " + f);
    }
    System.out.println("sum is " + sum);
    service.shutdownNow();
  }
 
}