package liu.dh.thread1; 
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 Demo6_callable { 
 /** 
  * @param args 
  * 使用Callable类创建线程 
  * public interface Callable<V>返回结果并且可能抛出异常的任务。实现者定义了一个不带任何参数的叫做 
  *  call 的方法。 Callable 接口类似于 Runnable,两者都是为那些其实例可能被另一个线程执行的类设计的。 
  *  但是 Runnable 不会返回结果,并且无法抛出经过检查的异常。  
                V call() 计算结果,如果无法计算结果,则抛出一个异常。 
  * @throws ExecutionException  
  * @throws InterruptedException  
  */ 
 public static void main(String[] args) throws InterruptedException, ExecutionException { 
  // TODO Auto-generated method stub 
  //创建线程池 
  ExecutorService eService = Executors.newSingleThreadExecutor(); 
  //将线程放入线程池 
  Future<Integer> sum1 = eService.submit(new MyCallable()); 
  //使用get获取结果 
   int sum = sum1.get(); 
   System.out.println(sum); 
   eService.shutdown();//关闭线程池 
 } 
} 
//实现接口,创建Callable实例 
class MyCallable implements Callable<Integer>{ 
 @Override 
 public Integer call() throws Exception { 
  // TODO Auto-generated method stub 
  int sum = 0; 
  for(int i  = 0;i <=1000;i++){ 
   sum = sum+i; 
    
  } 
  return sum; 
 } 
} 
 
 |   
        
 
    
    
    
     
 
 |