zoukankan      html  css  js  c++  java
  • Java线程之CompletionService

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

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

    [java] view plain copy
     
    1. public class Test {  
    2.     public static void main(String[] args) throws InterruptedException, ExecutionException {  
    3.         ExecutorService executor = Executors.newCachedThreadPool();  
    4.         CompletionService<Integer> comp = new ExecutorCompletionService<>(executor);  
    5.         for(int i = 0; i<5; i++) {  
    6.             comp.submit(new Task());  
    7.         }  
    8.         executor.shutdown();  
    9.         int count = 0, index = 1;  
    10.         while(count<5) {  
    11.             Future<Integer> f = comp.poll();  
    12.             if(f == null) {  
    13.                 System.out.println(index + " 没发现有完成的任务");  
    14.             }else {  
    15.                 System.out.println(index + "产生了一个随机数: " + f.get());  
    16.                 count++;  
    17.             }  
    18.             index++;  
    19.             TimeUnit.MILLISECONDS.sleep(500);  
    20.         }  
    21.     }  
    22. }  
    23.   
    24. class Task implements Callable<Integer> {  
    25.   
    26.     @Override  
    27.     public Integer call() throws Exception {  
    28.         Random rand = new Random();  
    29.         TimeUnit.SECONDS.sleep(rand.nextInt(7));  
    30.         return rand.nextInt();  
    31.     }  
    32.       
    33. }  
  • 相关阅读:
    visio 2019 激活方法
    sftp 多用户安装与配置
    CentOS configuration uses the SFTP server
    esxi命令行强行关闭虚拟机
    esxi 版本升级命令
    存储分析 开源重复数据删除技术崭露头角
    最简单-转换MBR为GPT
    CentOS 7 搭建本地YUM仓库,并定期同步阿里云源
    uml建模工具介绍
    C/C++中extern关键字详解
  • 原文地址:https://www.cnblogs.com/duanxz/p/3752374.html
Copyright © 2011-2022 走看看