有返回值的线程

========转载=========
在Java 线程中返回值的用法

博客分类： Java
Javathread
有时在执行线程中需要在线程中返回一个值；常规中我们会用Runnable接口和Thread类设置一个变量；在run()中改变变量的值，再用一个get方法取得该值，但是run何时完成是未知的；我们需要一定的机制来保证。

在在Java se5有个Callable接口；我们可以用该接口来完成该功能；

代码如：
Java代码 
package com.threads.test; 
 
import java.util.concurrent.Callable; 
 
public class CallableThread implements Callable<String> { 
    private String str; 
    private int count=10; 
    public CallableThread(String str){ 
        this.str=str; 
    } 
    //需要实现Callable的Call方法 
    public String call() throws Exception { 
        for(int i=0;i<this.count;i++){ 
            System.out.println(this.str+" "+i); 
        } 
        return this.str; 
    } 
} 


在call方法中执行在run（）方法中一样的任务，不同的是call（）有返回值。
call的返回类型应该和Callable<T>的泛型类型一致。
测试代码如下：
Java代码 
package com.threads.test; 
 
import java.util.ArrayList; 
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) { 
        ExecutorService exs=Executors.newCachedThreadPool(); 
        ArrayList<Future<String>> al=new ArrayList<Future<String>>(); 
        for(int i=0;i<10;i++){ 
            al.add(exs.submit(new CallableThread("String "+i))); 
        } 
         
        for(Future<String> fs:al){ 
            try { 
                System.out.println(fs.get()); 
            } catch (InterruptedException e) { 
                e.printStackTrace(); 
            } catch (ExecutionException e) { 
                e.printStackTrace(); 
            } 
        } 
    } 
 
} 

submit()方法返回一个Futrue对象，可以通过调用该对象的get方法取得返回值。
通过该方法就能很好的处理线程中返回值的问题。












  如果希望调用的线程不但能执行指定的任务，还想有返回值，这时我们就可以使用Callable与Future接口来实现。至于它的方法可以去查找相关API。下面来看一个例子：
package wyf.jc;
import java.util.concurrent.*;
//实现了Callable接口的任务类
class MyCallableImpl implements Callable{
String taskName;
public MyCallableImpl(String taskName){
  this.taskName=taskName;
}
//存放任务代码的run
public Object call(){
  System.out.println(taskName+"任务成功执行！");
  return "恭喜你，任务成功执行，我是返回消息";
}
}
public class sample17_6 {
/**
  * @param args
  */
public static void main(String[] args) {
  //创建线程
  ExecutorService threadPool=Executors.newSingleThreadExecutor();
  //调用线程池的submit方法执行任务
  Future future=threadPool.submit(new MyCallableImpl("taskA"));
  try{
   //调用阻塞方法get获取任务的返回值
   System.out.println(future.get());
  }catch(Exception ex){
   ex.printStackTrace();
  }
  threadPool.shutdown();
}
}
运行结果如下：
taskA任务成功执行！
恭喜你，任务成功执行，我是返回消息