设为首页 加入收藏

TOP

多线程――实现Callable接口
2015-07-24 05:47:27 来源: 作者: 【 】 浏览:5
Tags:线程 实现 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
  
   > set = new HashSet
   
    >(); for (String word: words) { Callable
    
      callable = new testCallable(word); Future
     
       future = pool.submit(callable); set.add(future); } int sum = 0; for (Future
      
        future : set) { try { sum += future.get(); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } System.out.println("数组中所有单词的总长度为:" + sum); } } class testCallable implements Callable
       
        { 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中创建线程的三种方法都以介绍完毕。当然,了解了这些只能说明对于多线程你刚刚入门,更多关于多线程的知识还有待于我们继续发掘,深入研究。

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
分享到: 
上一篇CodeForces 21C Stripe 2 构造题 下一篇最长单调子序列求解

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容: