《关于Java多线程处理》

package org.tempuri;
import java.util.concurrent.*;
import java.util.Date;
import java.util.List;
import java.util.ArrayList;
/**
 * * Java线程：有返回值的线程 
 * @author wb_qiuquan.ying
 */

public class Test {
 @SuppressWarnings("rawtypes")
 public static void main(String[] args) throws ExecutionException,
   InterruptedException {
  int sizeNum = 5;
  // 建立一个线程池
  ExecutorService pool = Executors.newFixedThreadPool(sizeNum);
  // 建立多个有返回值的任务
  List<Future> list = new ArrayList<Future>();
  for (int i = 0; i < sizeNum; i++) {
//   Callable c = new MyCallable(i + " ");也能够这样写，运行结果同样
   MyCallable c = new MyCallable(i + " ");
   
   // 执行任务并获取Future对象
   Future f = pool.submit(c);
   System.out.println("线程运行中此线程的值是:" + f.get().toString());
   list.add(f);
  }
  // 关闭线程池
 pool.shutdown();
  // 获取全部并发任务的运行结果
  System.out.println("");
  for (Future f : list) {
   // 从Future对象上获取任务的返回值，并输出到控制台
   System.out.println("关闭线程池后,各个线程的值:"+ f.get().toString());
  }
  
  System.exit(0);
 }
}
class MyCallable implements Callable<Object> {
 private String taskNum;
 MyCallable(String taskNum) {
  this.taskNum = taskNum;
 }
    //call()方法
 public Object call() throws Exception {
  System.out.println(">>>" + taskNum + "call()方法任务启动");
  Date dateTmp1 = new Date();
  Thread.sleep(1000);
  Date dateTmp2 = new Date();
  long time = dateTmp2.getTime() - dateTmp1.getTime();
  System.out.println(">>>" + taskNum + "任务终止");
  return "线程"+taskNum + "返回运行的时间【" + time + "毫秒】";
 }
}