Callable 與 Future

import java.util.ArrayList;
import java.util.List;
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 CallableTest {

	// 異步 木桶原理
	 public static void main(String[] args) throws InterruptedException, ExecutionException {
		 ExecutorService executorService = Executors.newCachedThreadPool(); 
	    int num = 5;
	    System.out.println(System.currentTimeMillis());
		 List<Future<String>> resultList = new ArrayList<Future<String>>(); 
	    for (int i = 0; i < num; i++) {
	    	Future<String> futureTask = executorService.submit(new TaskCallable(i));
	    	resultList.add(futureTask);
		}
	    System.out.println(System.currentTimeMillis());
	    for (Future<String>  future: resultList) {
			System.out.println(future.get());
		}
	    System.out.println(System.currentTimeMillis());
	 }
	 
	 public static class  TaskCallable  implements Callable<String>{

		 private int taskId;
		 
		public TaskCallable(int taskId) {
			this.taskId = taskId;
		}


		@Override
		public String call() throws Exception { 
			 Thread.sleep(taskId*1000);
			return "taskId="+taskId+",time="+System.currentTimeMillis();
		}
		 
	 }
}      

捐助開發者 

在興趣的驅動下,寫一個

免費

的東西，有欣喜，也還有汗水，希望你喜歡我的作品，同時也能支援一下。 當然，有錢捧個錢場（支援支付寶和微信 以及扣扣群），沒錢捧個人場，謝謝各位。

個人首頁

：

http://knight-black-bob.iteye.com/

 謝謝您的贊助，我會做的更好！