Callable接口实现多线程

Runnable是执行工作的独立任务，但是它不返回任何值。在Java SE5中引入的Callable是一种具有类型参数的泛型，它的类型参数表的是从方法call()中返回的值，并且必须使用ExecutorServices.submit()方法调用它，下面是一个简单示例。

<span style="font-size:14px;">package com.ftx.test;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class Thread_callable {

public static void main(String[] args) {
ExecutorService service=Executors.newCachedThreadPool();
List<Future<String>> results=new ArrayList<Future<String>>();
for(int i=0;i<10;i++){
results.add(service.submit(new Counter2("Thread"+i, 10)));
}

for (Future<String> future : results) {
System.out.println(future.isDone());
try {
System.out.println(future.get());
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}finally{
service.shutdown();
}

}
}

}

class Counter2 implements Callable<String>{

private String name;
private int count;

public Counter2(String name,int count) {
// TODO Auto-generated constructor stub
this.name=name;
this.count=count;

}

public String call() throws Exception {
String result=null;
while(count-->0){

result=name+"----count------"+count;
}
return result;
}

}</span>true

Thread0----count------0

true

Thread1----count------0

true

Thread2----count------0

true

Thread3----count------0

true

Thread4----count------0

true

Thread5----count------0

true

Thread6----count------0

true

Thread7----count------0

true

Thread8----count------0

true

Thread9----count------0

submit()方法回产生Future对象，它用Callable返回结果的特定类型进行了参数化。可以用isDone()方法来查询Future是否已经完成，当任务完成时，它具有一个结果，可以调用get()方法获取该结果。也可以不用isDone()进行检查就直接调用get()，在这种情况下，get()将阻塞，直至结果准备就绪。还可以在试图调用get()来获取结果之前，先调用具有超时的get()，或者调用isDone()来查看任务是否完成。