码迷,mamicode.com
首页 > 编程语言 > 详细

Java线程之CompletionService

时间:2014-09-10 15:45:20      阅读:176      评论:0      收藏:0      [点我收藏+]

标签:style   blog   http   color   io   使用   java   ar   for   

转自:http://blog.csdn.net/andycpp/article/details/8902699

当使用ExecutorService启动了多个Callable后,每个Callable会产生一个Future,我们需要将多个Future存入一个线性表,用于之后处理数据。当然,还有更复杂的情况,有5个生产者线程,每个生产者线程都会创建任务,所有任务的Future都存放到同一个线性表中。另有一个消费者线程,从线性表中取出Future进行处理。

CompletionService正是为此而存在,它是一个更高级的ExecutorService,它本身自带一个线程安全的线性表,无需用户额外创建。它提供了2种方法从线性表中取出结果,poll()是非阻塞的,若目前无结果,返回一个null,线程继续运行不阻塞。take()是阻塞的,若当前无结果,则线程阻塞,直到产生一个结果,被取出返回,线程才继续运行。

public class Test {  
    public static void main(String[] args) throws InterruptedException, ExecutionException {  
        ExecutorService executor = Executors.newCachedThreadPool();  
        CompletionService<Integer> comp = new ExecutorCompletionService<>(executor);  
        for(int i = 0; i<5; i++) {  
            comp.submit(new Task());  
        }  
        executor.shutdown();  
        int count = 0, index = 1;  
        while(count<5) {  
            Future<Integer> f = comp.poll();  
            if(f == null) {  
                System.out.println(index + " 没发现有完成的任务");  
            }else {  
                System.out.println(index + "产生了一个随机数: " + f.get());  
                count++;  
            }  
            index++;  
            TimeUnit.MILLISECONDS.sleep(500);  
        }  
    }  
}  
  
class Task implements Callable<Integer> {  
  
    @Override  
    public Integer call() throws Exception {  
        Random rand = new Random();  
        TimeUnit.SECONDS.sleep(rand.nextInt(7));  
        return rand.nextInt();  
    }  
      
}  

 

Java线程之CompletionService

标签:style   blog   http   color   io   使用   java   ar   for   

原文地址:http://www.cnblogs.com/gisblogs/p/3964476.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!