Java多线程之Callable接口的实现

public interface Callable<V> 
{ 
 V call() throws Exception; 
} 

public interface Runnable {
 public abstract void run();
}

class MyCallableTask implements Callable<Integer>{
 @Override
 public Integer call() throws Exception {
  System.out.println("线程在进行计算");
  Thread.sleep(3000);
  int sum = 0;
  for(int i=0;i<100;i++)
   sum += i;
  return sum;
 }
}

Callable<Integer> mycallabletask = new MyCallableTask(); 
FutureTask<Integer> futuretask= new FutureTask<Integer>(mycallabletask); 
new Thread(futuretask).start();

public interface ExecutorService extends Executor {

 //提交一个Callable任务，返回值为一个Future类型
 <T> Future<T> submit(Callable<T> task);

 //other methods...
 }

 ExecutorService exec = Executors.newCachedThreadPool();
 Future<Integer> future = exec.submit(new MyCallableTask());

public class CallableAndFutureTask {
 public static void main(String[] args) {
  Callable<Integer> callable = new Callable<Integer>() {
   public Integer call() throws Exception {
    return new Random().nextInt(100);
   }
  };
  FutureTask<Integer> future = new FutureTask<Integer>(callable);
  new Thread(future).start();
  try {
   Thread.sleep(5000);
   System.out.println(future.get());
  } catch (InterruptedException e) {
   e.printStackTrace();
  } catch (ExecutionException e) {
   e.printStackTrace();
  }
 }
}

public class CallableAndFuture {
 public static void main(String[] args) {
  ExecutorService threadPool = Executors.newSingleThreadExecutor();
  Future<Integer> future = threadPool.submit(new Callable<Integer>() {
   public Integer call() throws Exception {
    return new Random().nextInt(100);
   }
  });
  try {
   Thread.sleep(5000);// 可能做一些事情
   System.out.println(future.get());
  } catch (InterruptedException e) {
   e.printStackTrace();
  } catch (ExecutionException e) {
   e.printStackTrace();
  }
 }
}

class MyCallableTask implements Callable<String> {
 private int id; 
 public OneTask(int id){ 
  this.id = id; 
 } 
 @Override 
 public String call() throws Exception { 
  for(int i = 0;i<5;i++){
   System.out.println("Thread"+ id); 
   Thread.sleep(1000); 
  } 
  return "Result of callable: "+id; 
 } 
}
public class Test { 

 public static void main(String[] args) { 
  //Callable<String> mycallabletask = new MyCallableTask(1); 
  ExecutorService exec = Executors.newCachedThreadPool(); 
  ArrayList<Future<String>> results = new ArrayList<Future<String>>();  

  for (int i = 0; i < 5; i++) { 
   results.add(exec.submit(new MyCallableTask(i))); 
  } 

  for (Future<String> fs : results) { 
   if (fs.isDone()) { 
    try { 
     System.out.println(fs.get()); 
    } catch (Exception e) { 
     e.printStackTrace(); 
    } 
   } else { 
    System.out.println("MyCallableTask任务未完成！"); 
   } 
  } 
  exec.shutdown(); 
 } 
}