ExecutorService threadPool = Executors.newFixedThreadPool(1);
CompletionService<Object> completeService = new ExecutorCompletionService<Object>(
threadPool);
for (final HttpContentRetriever retriver : httpContentRetrievers) {
completeService.submit(new Runnable() {
@Override
public void run() {
try {
performParseAndAggregate(retriver.getInputStream(),
filePath, startDate, endDate, parserTyper,
pivotCallback);
} catch (Exception e) {
e.printStackTrace();
}
}
}, null);
}
for (int i = 0; i < httpContentRetrievers.length; i++) {
try {
completeService.take();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
threadPool.shutdown();
Iterator<Map<String, Object>> iter = pivotCallback.createView()
.listAll();
分享到:
相关推荐
java多线程处理数据库数据,使用并发包,无框架,可批量处数据库数据,进行增删改。。等等操作。
java多线程处理大数据,可根据配置的线程数,任务去调度处理
java 多媒体与多线程处理实验 java实验报告
相机采集、处理、显示多线程处理是指使用多个线程来同时执行相机数据采集、处理和显示的操作。其中采集线程负责从相机中获取图像数据,处理线程负责对采集到的图像数据进行处理和算法分析,显示线程负责将处理后的...
VB2008多线程处理,基于后台处理控件BackgroundWorker
winform 编写工具,多线程处理数据工具模版,实现多线程异步更新UI等操作
包括服务器端和客户端源码,采用C#实现服务器与客户端通过TCP协议进行数据通信,对于多个连接的客户端,服务器端采用多线程处理客户端发送的数据。
Qt线程池,实现多个任务抢占多线程调度功能,用Qt事件循环解决假死
java多线程处理数据(csdn)————程序
windows编程中的多线程处理PPT,希望有助于大家对多线程处理的学习有帮助。
多线程处理视频时,由于不同线程处理速度不同步,不同线程之间的数据传递需要进行缓冲处理。单块缓存的互斥操作或两块缓存的乒乓操作在大多数情况下不够用(数据流不平稳时丢数据);附件中利用C++实现了一个调用...
多线程处理事件,投递事件,子线程处理完成后,交给主线程结果;
实用的真正的VB多线程处理的例子,源代码 我本人已经测试过了,没有任何问题!!,请不要随便枉下评论~~!!! (内部有两个工程,测试的时候需要全部运行!!) 在评论前,请先仔细的分析一下代码,~根据自己的需要在做适当修改~. ...
Revit二次开发 c# 本身revit无法进行多线程处理,本实例实现多线程处理
多线程处理是创建可以响应的智能客户端应用程序的重要部分,本文整理、概括与梳理了NET多线程处理的知识,主要包含:1)同步和异步调用之间的选择;2)前台线程和后台线程之间的选择;3)处理锁定和同步;4)何时使用...
基于python的多线程例子,详细介绍了多线程处理,便于理解多线程
C写的SOCKET写的服务端程序 多线程处理客户端请求 C写的SOCKET写的服务端程序 多线程处理客户端请求 C写的SOCKET写的服务端程序 多线程处理客户端请求
libevent多线程处理的一种实现方式,学习libevent后自己实现的记录