平时在工作中一般用到的多线程为：一种是直接继承Thread，另外一种就是实现Runnable接口，但是在最近工作遇到一个问题，希望线程执行完后返回结果。哦哦，上面两种都不允许有返回值，悲剧了。
一、来源
而自从Java 1.5开始，开始提供了Callable和Future，通过它们可以在任务执行完毕之后得到任务执行结果。
二、简单对比Runnable与Callable
1.Runnable是在java.lang.Runnable包下面，没有返回值，而Callable是在java.util.concurrent包下面（说明一个问题Callable是为并发编程做准备的）可以有返回值。这里故意把java.util.concurrent标红，是因为并发编程里面所用到的类或接口都在该包下面。
2.Callable不能使用Thread来直接执行，一般情况下面使用ExecutorService中的submit方法类执行，Runnable使用ExecutorService的execute来执行。
3.Runnable接口里面有一个run()方法，Callable接口里面有一个call()，有返回值，可以抛出异常。
以上这些差异可以查看接口源码看出。
三、Future
Future就是对于具体的Runnable或者Callable任务的执行结果进行取消、查询是否完成、获取结果。必要时可以通过get方法获取执行结果，该方法会阻塞直到任务返回结果。
在Future接口中声明了5个方法，下面依次解释每个方法的作用：
- cancel方法用来取消任务，如果取消任务成功则返回true，如果取消任务失败则返回false。参数mayInterruptIfRunning表示是否允许取消正在执行却没有执行完毕的任务，如果设置true，则表示可以取消正在执行过程中的任务。如果任务已经完成，则无论mayInterruptIfRunning为true还是false，此方法肯定返回false，即如果取消已经完成的任务会返回false；如果任务正在执行，若mayInterruptIfRunning设置为true，则返回true，若mayInterruptIfRunning设置为false，则返回false；如果任务还没有执行，则无论mayInterruptIfRunning为true还是false，肯定返回true。
- isCancelled方法表示任务是否被取消成功，如果在任务正常完成前被取消成功，则返回 true。
- isDone方法表示任务是否已经完成，若任务完成，则返回true；
- get()方法用来获取执行结果，这个方法会产生阻塞，会一直等到任务执行完毕才返回；
- get(long timeout, TimeUnit unit)用来获取执行结果，如果在指定时间内，还没获取到结果，就直接返回null。
也就是说Future提供了三种功能：
1）判断任务是否完成；
2）能够中断任务；
3）能够获取任务执行结果。
因为Future只是一个接口，所以是无法直接用来创建对象使用的，因此就有了下面的FutureTask。
以上有部分文字是我直接粘贴过来的，参看网址为：
http://www.cnblogs.com/dolphin0520/p/3949310.html
四、代码示例，通过三种方式执行Callable拿到返回值
package cn.thread.first.callable;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;
/**
* Callable可以有返回值,而Runnable不能有返回值
*/
class TaskWithResult implements Callable<String> {
private int id;
public TaskWithResult(int id) {
this.id = id;
}
public String call() throws Exception {
System.out.println("ssssssss" + id);
return "result of TaskWithResult:id=" + id;
}
}
public class CallableDemo {
public static void main1(String orgs[]) throws ExecutionException, InterruptedException, TimeoutException {
//Executors.newSingleThreadExecutor()执行结果不一样哦
//Executors.newCachedThreadPool();
ExecutorService exec = Executors.newFixedThreadPool(1);
List<Future<String>> results = new ArrayList<Future<String>>();
for (int i = 0; i < 10; i++) {
//ExecutorService 在Callable中使用的是submit()， 在Runnable中使用的是 execute()
results.add(exec.submit(new TaskWithResult(i)));
}
results.add(exec.submit(new TaskWithResult(12)));
System.out.println(".............for add Future before");
for (Future<String> fs : results) {
if (fs.isDone()) {
System.out.println(fs.get());
System.out.println(fs.get(100L, TimeUnit.MILLISECONDS));
} else {
System.out.println("future result is null");
}
}
System.out.println(".............for Future after");
exec.shutdown();
}
public static void main2(String orgs[]) throws ExecutionException, InterruptedException, TimeoutException {
ExecutorService exec = Executors.newFixedThreadPool(1);
for (int i = 0; i < 10; i++) {
FutureTask<String> futureTask = new FutureTask<String>(new TaskWithResult(i));
exec.execute(futureTask);
if (futureTask.isDone()) {
System.out.println("future result is null");
}
if (!futureTask.isDone()) {
System.out.println(futureTask.get(100L, TimeUnit.MILLISECONDS));
} else {
System.out.println("isdone is null");
}
}
exec.shutdown();
System.out.println(".............for add Future before");
System.out.println(".............for Future after");
}
public static void main(String orgs[]) throws ExecutionException, InterruptedException {
ExecutorService exec = Executors.newFixedThreadPool(3);
CompletionService<String> cs = new ExecutorCompletionService<String>(exec);
for (int i = 0; i < 10; i++) {
cs.submit(new TaskWithResult(i));
}
//CompletionService,取值的时候按照执行的顺序取值
for (int i = 10; i > 0; i--) {
System.out.println("i..." + i + "......" + cs.take().get());
}
exec.shutdown();
System.out.println(".............for add Future before");
System.out.println(".............for Future after");
}
}
提交到CompletionService中的Future是按照完成的顺序排列的，这种做法中Future是按照添加的顺序排列的
http://blog.csdn.net/ghsau/article/details/7451464