并发编程回顾：Runnable与Callable

原先多线程并发编程的学习笔记和代码整理一下贴上来。

---------------------------------

Runnable与Callable

Runnable工作是执行独立的任务，它不具备任何返回值。如果需要任务需要完成后返回一个值，使用Callable接口。

一、Runnable：

无返回值(void)，如下

class Worker implements Runnable{
	private static int workerCount = 0; //线程总数
	private final int workId = workerCount++; //final初始化后值不会变
	private int workTime = 3; //每个线程执行3次
	public void run() {
		while(workTime-- > 0){
			System.out.println("workId:#"+workId+" workTime:"+workTime+" working...");
		}
	}
	
}

此处定义了一个Worker任务，每个任务内部打印Id和执行次数。

启动任务执行：new Thread(new Worker()).start()

二、Callable：

通过泛型的方式，指定返回值的类型，下面是一个返回String的例子。

class TaskWithResult implements Callable<String>{
	private int i=3;//每个线程执行3次
	public String call() throws Exception {
		while(true){
			if(--i==0) return "thread name:"+Thread.currentThread().getName();
		}
	}
}

定义一个任务，该任务执行3次，最后返回该线程名字。注意Callable指定了类型为<String>，因此call方法的返回值为String类型。

使用方法：

ExecutorService exec = Executors.newCachedThreadPool();
List<Future<String>> list = new ArrayList<Future<String>>();
for(int i=5;i>0;i--){
    list.add(exec.submit(new TaskWithResult()));
}
for(Future<String> fs:list){
    try {
	if(fs.isDone()){//如果task已经完成
	    System.out.println("callable return:"+fs.get());
	}else{
	    System.out.println("cancel:"+fs.cancel(true));
	    System.out.println("isCancelled:"+fs.isCancelled());
	}
    } catch (InterruptedException e) {
	e.printStackTrace();
    } catch (ExecutionException e) {
	e.printStackTrace();
    }finally{
	exec.shutdown();//关闭线程池.
    }
}

此处创建了一个线程池，启动5个任务，每次使用submit提交任务后会返回一个Future对象。

Future表示异步计算的结果,提供了检查计算是否完成的方法,以等待计算的完成,并检索计算的结果。

后面对Future列表进行遍历，检查每个task是否完成。如果还没有完成，直接取消任务。

注意，如果不使用isDone判断task是否执行完，使用Future的get方法会一直阻塞，直到任务完成。