多线程——实现Callable接口

前两篇博客（多线程——继承Thread类，多线程——实现Runnable接口
）介绍了java使用线程的两种方法，这篇博客继续介绍第三种方法——实现Callable接口。

先说一下Runnable和Callable的区别：

1、Callable规定的方法是call(),Runnable规定的方法是run().

2、Callable的任务执行后可返回值，而Runnable的任务是不能返回值得

3、call方法可以抛出异常，run方法不可以

4、运行Callable任务可以拿到一个Future对象，表示异步计算的结果。它提供了检查计算是否完成的方法，以等待计算的完成，并检索计算的结果。通过Future对象可以了解任务执行情况，可取消任务的执行，还可获取执行结果。

还沿用前两篇博客的例子，只不过这里稍作改动。现在我们不仅要输入单词的长度，而且还要求计算出字符串数组中所有单词的长度之和。

很明显，这样一改动，多线程的执行体就需要有一个返回值，用以计算所有单词的长度之和。而runnable中的run方法是不能有返回值的，所以，这里我们只能使用callable。具体代码如下：

package test;

import java.util.HashSet;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class Test1{
	public static void main(String [] args ) {
		String [] words = {"first","second","world","thread"};

		//创建一个线程池
		ExecutorService pool = Executors.newCachedThreadPool(  );
        Set<Future<Integer>> set = new HashSet<Future<Integer>>();

        for (String word: words) {
            Callable<Integer> callable = new testCallable(word);
            Future<Integer> future = pool.submit(callable);
            set.add(future);
        }
        int sum = 0;
        for (Future<Integer> future : set) {
            try {
				sum += future.get();
			} catch (InterruptedException e) {
				e.printStackTrace();
			} catch (ExecutionException e) {
				e.printStackTrace();
			}
        }
        System.out.println("数组中所有单词的总长度为：" + sum);
	}

}

class testCallable implements Callable<Integer>{
	private String word;

	public testCallable(String word){

		this.word = word;
	}

	@Override
	public Integer call() throws Exception {
		System.out.println(Thread.currentThread().getName() + ": 开始执行！" );
		try {
			//假设处理需要2秒
			Thread.currentThread().sleep(2000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println(Thread.currentThread().getName() + ": 正在处理！" );
		System.out.println(Thread.currentThread().getName() + ": " + word + "长度为：" + word.length());
		return Integer.valueOf(word.length());
	}
}

执行结果如下：

pool-1-thread-1: 开始执行！

pool-1-thread-3: 开始执行！

pool-1-thread-4: 开始执行！

pool-1-thread-2: 开始执行！

pool-1-thread-1: 正在处理！

pool-1-thread-1: first长度为：5

pool-1-thread-3: 正在处理！

pool-1-thread-3: world长度为：5

pool-1-thread-2: 正在处理！

pool-1-thread-2: second长度为：6

pool-1-thread-4: 正在处理！

pool-1-thread-4: thread长度为：6

数组中所有单词的总长度为：22

至此，java中创建线程的三种方法都以介绍完毕。当然，了解了这些只能说明对于多线程你刚刚入门，更多关于多线程的知识还有待于我们继续发掘，深入研究。

多线程——实现Callable接口