一 理论

Runnable是执行工作的独立任务，但是不返回任何值。如果我们希望任务完成之后有返回值，可以实现Callable接口。在JavaSE5中引入的Callable是一个具有类型参数的范型，他的类型参数方法表示为方法call()而不是run()中返回的值，并且必须使用ExecutorService.submint()方法进行调用。

二 示例

//实现接口Callable 参数类型是String

public class TaskWithResult implements Callable {

private int id;

public TaskWithResult(int id){

this.id=id;

}

@Override

public String call() throws Exception {

return "result of TaskWithResult "+id;

}

}

//java测试方法，基于junit4

@Test

public void main2() {

ExecutorService exec= Executors.newCachedThreadPool();

//Future接口后面有源码

ArrayList> results=new ArrayList>();

long start=System.currentTimeMillis();

for(int i=0;i<10;i++){

results.add(exec.submit(new TaskWithResult(i)));

}

//System.out.println("====================cost:"+(System.currentTimeMillis()-start));

int count=0;

//遍历数据

for(Future fs:results){

//System.out.println("========cost:"+(System.currentTimeMillis()-start));

long start2=System.currentTimeMillis();

try{

//取数据

System.out.println(fs.get());

}catch (InterruptedException e){

System.out.print(e);

}catch (ExecutionException e){

System.out.print(e);

}finally {

exec.shutdown();

}

//System.out.println((count++)+"====================cost:"+(System.currentTimeMillis()-start2));

}

}

执行结果如下图：

result.png

三Callable接口源码

@FunctionalInterface

public interface Callable {

/**

* Computes a result, or throws an exception if unable to do so.

*

* @return computed result

* @throws Exception if unable to compute a result

*/

V call() throws Exception;

}

四 Future 接口源码

public interface Future {

//取消

boolean cancel(boolean mayInterruptIfRunning);

boolean isCancelled();

//任务是否完成

boolean isDone();

//获得数据

V get() throws InterruptedException, ExecutionException;

V get(long timeout, TimeUnit unit)

throws InterruptedException, ExecutionException, TimeoutException;

}