`

CompleteService介绍和使用实例

阅读更多

当向Executor提交批处理任务时,并且希望在它们完成后获得结果,如果用FutureTask,你可以循环获取task,并用future.get()去获取结果,但是如果这个task没有完成,你就得阻塞在这里,这个实效性不高,其实在很多场合,其实你拿第一个任务结果时,此时结果并没有生成并阻塞,其实在阻塞在第一个任务时,第二个task的任务已经早就完成了,显然这种情况用future task不合适的,效率也不高的,实例如下:

 

实例一:用一个非complete Service完成的批量任务

package completeservice;

import java.util.Random;
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;
import java.util.concurrent.FutureTask;


/**
 *
 *<p>Test</p>
 *<p>Description:</P>
 *<p>Company:Cisco CAS</p>
 *<p>Department:CAS</p>
 *@Author: Tommy Zhou
 *@Since: 1.0
 *@Version:Date:2011-5-11
 *
 **/

public class NonCompleteServiceTest {
   
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        Future<String>[] futures = new FutureTask[10];
       
        /**
         * 产生一个随机数,模拟不同的任务的处理时间不同
         */
        for (int i = 0; i < 10; i++) {
            futures[i] = executorService.submit(new Callable<String>() {
                public String call(){
                    int rnt = new Random().nextInt(5);
                   
                    try {
                        Thread.sleep(rnt*1000);
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    System.out.println("run rnt = "+rnt);
                    return String.valueOf(rnt*1000);
                }
            });
        }
       
        /**
         * 获取结果时,如果任务没有完成,则阻塞,在顺序获取结果时,
         * 可能别的任务已经完成,显然效率不高
         */
        for (int i = 0; i < futures.length; i++) {
            System.out.println(futures[i].get());
        }
        executorService.shutdown();
    }

}

 

package completeservice;

import java.util.Random;
import java.util.concurrent.Callable;
import java.util.concurrent.CompletionService;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorCompletionService;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

/**
 *
 *<p>Test</p>
 *<p>Description:</P>
 *<p>Company:Cisco CAS</p>
 *<p>Department:CAS</p>
 *@Author: Tommy Zhou
 *@Since: 1.0
 *@Version:Date:2011-5-11
 *
 **/

public class CompleteServiceTest {
public static void main(String[] args) throws InterruptedException, ExecutionException {
    ExecutorService executorService = Executors.newFixedThreadPool(10);
   
   
    CompletionService<String> completionService = new ExecutorCompletionService<String>(executorService);
   
    /**
     * 产生一个随机数,模拟不同的任务的处理时间不同
     */
    for (int i = 0; i < 10; i++) {
        completionService.submit(new Callable<String>() {
            public String call(){
                int rnt = new Random().nextInt(5);
               
                try {
                    Thread.sleep(rnt*1000);
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                System.out.println("run rnt = "+rnt);
                return String.valueOf(rnt*1000);
            }
        });
    }
   
    /**
     * 获取结果时,总是先拿到队列上已经存在的对象,这样不用依次等待结果
     * 显然效率更高
     */
    for (int i = 0; i < 10; i++) {
        Future<String> future = completionService.take();
        System.out.println(future.get());
    }
    executorService.shutdown();
}
}

 

 

分享到:
评论
1 楼 coolboyysy 2013-07-23  

相关推荐

    GDB调试精粹及使用实例GDB调试精粹及使用实例

    GDB调试精粹及使用实例GDB调试精粹及使用实例GDB调试精粹及使用实例GDB调试精粹及使用实例GDB调试精粹及使用实例GDB调试精粹及使用实例GDB调试精粹及使用实例GDB调试精粹及使用实例GDB调试精粹及使用实例GDB调试精粹...

    Openairinterface项目介绍以及使用实例

    Openairinterface项目介绍以及使用实例,个人根据工作经验和需求,对Openairinterface项目进行了介绍,主要包括项目的功能和历史,并对5G研究做了概述。

    QT5开发及实例配套源代码.zip

    Qt是诺基亚公司的C++可视化开发平台,本书以Qt 5作为平台,每个章节在简单介绍开发环境的基础上,用一个小实例,介绍Qt 5应用程序开发各个方面,然后系统介绍Qt 5应用程序的开发技术,一般均通过实例介绍和讲解内容...

    OpenStack web界面使用ISO镜像安装启动实例

    本文将深入探讨如何通过Horizon使用ISO镜像来安装和启动一个新的实例。 首先,ISO镜像是一个标准的光盘映像格式,通常用于存储软件安装程序,如操作系统。在OpenStack中,ISO镜像可以作为启动源,让用户能够像在...

    欧姆龙PLC的FINS通讯手册与使用实例解析

    这份资源集合了FINS通讯手册、FINS命令协议以及丰富的使用实例,旨在帮助用户理解和掌握如何高效地与欧姆龙可编程控制器(PLC)进行数据交换。 FINS(Fieldbus Network System)是欧姆龙公司开发的一种网络通信协议...

    sqlserver2008R2应用添加实例步骤

    - 使用实例名称和之前设置的登录凭证进行连接,以验证是否成功。 **步骤9:数据库还原** - 如果需要将现有的数据库还原到新实例中,请确保数据库名称保持不变。 - 使用SSMS或其他工具将数据库文件导入新实例,并...

    C# WebSocket使用实例源码,包含服务端和客户端

    总的来说,这个"C# WebSocket使用实例"是一个很好的学习资源,它涵盖了WebSocket的基本概念和C#实现细节。通过研究和运行这个示例,开发者可以更好地理解和掌握WebSocket在实际项目中的应用,特别是在需要实时数据...

    linux下oracle安装两个实例一个监听的配置

    本文将详细介绍如何在Linux下为两个Oracle实例配置一个监听器的过程,包括关键配置文件`listener.ora`和`tnsnames.ora`的设置。 ### 一、理解监听器与实例的关系 监听器是Oracle数据库中的一个重要组件,它负责...

    伪代码实例介绍-规则与实例

    通过这些实例,学习者可以了解如何使用伪代码来解决实际问题,熟悉其结构和逻辑,为后续的编程实现打下坚实基础。在编写伪代码时,应保持清晰和一致的风格,确保每个步骤都能准确地映射到实际的编程实现中。同时,伪...

    labview55个经典实例

    12. **子VI和函数库**:通过创建子VI,可以实现代码重用和模块化,实例将展示如何创建和使用子VI。 13. **数据可视化**:LabVIEW强大的图表和图形功能会在实例中得到体现,如实时波形显示、数据统计图、3D图形等。 ...

    python 脚本实例 编程实例 入门实例

    本文将深入探讨这些"python 脚本实例 编程实例 入门实例",帮助你理解Python的基本概念和常用操作。 1. **变量与数据类型** Python中的数据类型包括整型(int)、浮点型(float)、字符串(str)和布尔型(bool)...

    100个C#初学者编程实例

    10. **LINQ查询**:学习使用Language Integrated Query(LINQ)可以更高效地处理数据,实例会介绍如何使用LINQ进行数据库查询、集合筛选等操作。 11. **多线程**:C#支持并发编程,通过Thread类和Task类,初学者...

    FPGA数字系统设计实例(带书签版本)

    本书介绍了使用Quartus Ⅱ7.0开发FPGA/CPLD数字系统的开发流程和设计方法,通过实例讲解,介绍了数字电路设计的原理图编辑、文本编辑和混合编辑的方法,并对大型数字系统设计实例进行了解析。本书还介绍了宏功能模块及...

    MSC.ADAMS技术与工程分析实例

    《MSC.ADAMS技术与工程分析实例》是一本专为机械工程和制造行业从业者设计的指南,旨在帮助读者理解和掌握虚拟样机仿真技术的核心工具——MSC.ADAMS。本书通过丰富的实例,深入浅出地介绍了如何运用ADAMS进行工程...

    十天学会单片机实例100

    ### 函数的使用和熟悉 函数是单片机编程中的基本构建块,用于组织代码和重复使用功能。通过理解和运用函数,可以提高代码的模块化程度和可读性。例如,在实例3中,控制单片机点亮第一个灯的过程中,可以创建一个`...

    ABAQUS_6.6基础教程与实例详解

    书中详细介绍了ABAQUS各功能模块的常用设置和使用技巧,使读者能够全面了解软件的使用,以操作菜单系统的方式进行学习。书中的实例选择覆盖了各种工程领域,每个实例都经过精心设计,旨在通过实例操作的讲解让读者...

    Visual C# .NET精彩编程实例集锦

    实例1 如何使用错误提醒控件 实例2 如何使用信息提示控件 实例3 如何使用菜单控件 实例4 如何使用工具栏控件 实例5 如何使用状态栏控件 实例6 如何使用托盘控件 实例7 如何使用标签页控件 实例8 如何使用进度条控件 ...

    C++编程实例100篇

    《C++编程实例100篇》是一本深入浅出的C++编程教程,它以实践为主导,通过丰富的实例帮助学习者掌握C++语言的基础和核心概念。这本书的每个实例都精心设计,旨在帮助初学者和有经验的开发者巩固和提升C++编程技能。 ...

    C#开发实例大全(基础卷/1.69G/光盘)(提高卷/2.9G/光盘)

    - **流操作**:介绍使用流(如FileStream、StreamReader等)处理数据的方法。 - **序列化与反序列化**:解释如何将对象序列化为文件或从文件反序列化为对象。 ### C#开发实例大全(提高卷) #### 1. 高级编程技术 ...

Global site tag (gtag.js) - Google Analytics