CompletionService相当于Executor加上BlockingQueue,使用场景为当子线程并发了一系列的任务以后,主线程需要实时地取回子线程任务的返回值并同时顺序地处理这些返回值,谁先返回就先处理谁。下面两个类的工作效果相同,一个使用了CompletionService,代码更简捷些,一个直接使用的Executort和BlockingQueue,更复杂一些。其实读CompletionService的源代码,可以发现它内部其实就是对Executor和BlockingQueue的一个封装,不过封装后确定很优雅,用起来很方便。
1.TestCompletionService.java
package test;
import java.io.File;
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;
public class TestCompletionService {
private static final ExecutorService NEW_FIXED_THREAD_POOL = Executors.newFixedThreadPool(10);
private static final File[] in = { new File("in1"),
new File("in2"), new File("in3"), new File("in4"), new File("in5") };
private static File out = new File("out");
private static CompletionService<File> completionService = new ExecutorCompletionService<File>(
NEW_FIXED_THREAD_POOL);
private static class DownLoader<File> implements Callable<File> {
private int index;
public void setIndex(int index) {
this.index = index;
}
@Override
public File call() throws Exception {
try {
Thread.sleep(index * 10000);
System.out.println("sleet [" + index * 10000 + "];");
} catch (InterruptedException e) {
System.out.println(e);
}
System.out.println("put file [" + in[index] + "];" + "time ["
+ System.currentTimeMillis() + "];");
return (File) in[index];
}
}
/**
* @param args
*/
public static void main(String[] args) {
for (int i = 0; i < 5; i++) {
DownLoader<File> downLoader = new DownLoader<File>();
downLoader.setIndex(i);
completionService.submit(downLoader);
}
for (int i = 0; i < 5; i++) {
try {
Future<File> future = completionService.take();
File file = future.get();
System.out.println("take file [" + file + "];" + "time ["
+ System.currentTimeMillis() + "];");
} catch (InterruptedException e) {
System.out.println(e);
} catch (ExecutionException e) {
System.out.println(e);
}
}
NEW_FIXED_THREAD_POOL.shutdown();
System.out.println("ok");
}
}
2.TestBlockingQueue.java
package test;
import java.io.File;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class TestBlockingQueue {
private static File[] in = { new File("in1"), new File("in2"),
new File("in3"), new File("in4"), new File("in5") };
private static File out = new File("out");
private static ExecutorService executorService = Executors.newFixedThreadPool(10);
private static class DownLoader implements Runnable {
private int index;
private BlockingQueue<File> blockingQueue;
public void setBlockingQueue(BlockingQueue<File> blockingQueue) {
this.blockingQueue = blockingQueue;
}
public void setIndex(int index) {
this.index = index;
}
@Override
public void run() {
try {
Thread.sleep(index * 10000);
System.out.println("sleet [" + index * 10000 + "];");
} catch (InterruptedException e) {
System.out.println(e);
}
if (index == 3) {
}
try {
System.out.println("put file [" + in[index] + "];" + "time ["
+ System.currentTimeMillis() + "];");
blockingQueue.put(in[index]);
} catch (InterruptedException e) {
System.out.println(e);
}
}
}
/**
* @param args
*/
public static void main(String[] args) {
BlockingQueue<File> blockingQueue = new ArrayBlockingQueue<File>(10);
for (int i = 0; i < 5; i++) {
DownLoader downLoader = new DownLoader();
downLoader.setBlockingQueue(blockingQueue);
downLoader.setIndex(i);
executorService.execute(downLoader);
}
for (int i = 0; i < 5; i++) {
try {
File file = blockingQueue.poll(8, TimeUnit.SECONDS);
System.out.println("take file [" + file + "];" + "time ["
+ System.currentTimeMillis() + "];");
} catch (InterruptedException e) {
System.out.println(e);
}
}
executorService.shutdown();
System.out.println("ok");
}
}
分享到:
相关推荐
本文将深入探讨Java项目中最简单的多线程使用方法,通过一个名为"thread-test"的示例项目来讲解如何在企业实际场景中应用多线程。 一、Java多线程基础 1. **Thread类与Runnable接口** Java中实现多线程有两种方式...
辣椒油树脂检验表格(食品添加剂食用香精质量验收记录表).docx
字体路径文件
Screenshot_2025-03-14-16-46-14-26.jpg
交警队伍管理制度.docx
乳酸链球菌素检验表格(食品添加剂食用香精质量验收记录表).docx
编译的axel windows工具,有需要的拿去 使用命令例子如下 cmd 界面下cd 到axel.exe 文件路径 比如下载image net 1k axel -n 8 -o ./ https://image-net.org/data/ILSVRC/2012/ILSVRC2012_img_train.tar --insecure 编译过程的记录为 https://blog.csdn.net/Magicapprentice/article/details/146250906?sharetype=blogdetail&sharerId=146250906&sharerefer=PC&sharesource=Magicapprentice&spm=1011.2480.3001.8118 可以参照这个链接从零开始自己编译
羧甲基淀粉钠检验表格(食品添加剂食用香精质量验收记录表).docx
光学多层膜系统模拟仿真matlab代码 这段代码是一个光学多层膜系统的模拟程序,计算了TE模和TM模的反射率,并绘制了反射率随波长和入射角变化的等高线图。 这里是代码的主要流程: 1. 加载材料参数数据(Al2O3、Si3N4、SiO2、Ag)和波长数据(lambda)。 2. 循环遍历不同的入射角度(theta0)。 3. 对于每个入射角度,计算TE模和TM模的传输矩阵,包括各个层的传输矩阵。 4. 计算反射率,并将TE模和TM模的反射率取平均作为总的反射率。 5. 将总的反射率随波长和入射角度的变化绘制成等高线图。 这段代码非常详细,而且注释也很清晰,让人容易理解。 不过最后一行的中文注释应该是解释如何使用`colormap`函数来设置绘图的颜色映射,可以将其翻译为“设置颜色映射为Jet色彩”。 ,多层膜系统模拟; TE模和TM模反射率计算; 波长和入射角变化; 传输矩阵; 平均反射率; 绘制等高线图; 颜色映射设置。,光学多层膜系统模拟仿真:Matlab代码实现
中国城市统计年鉴全集(1985-2022).zip。内容来源于网络分享,如有侵权请联系我删除。
双向DC DC全钒液流蓄电池充放电储能matlab simulink仿真模型,采用双闭环控制,充放电电流和电压均可控,直流母线端电压可控,电流为负则充电,电流为正则放电,可以控制电流实现充放电 (1)完整复现文献全钒液流模型,多个全钒液流电池串联成电池组,提供模型参数,电压等级可调 (2)可通过电流环控制电池充放电电流,可实现不同充放电电流,控制速度快(电流闭环) (3)可通过电压环控制电池两端充放电电压,可实现不同充放电电流,控制速度快(电压闭环) ,全钒液流电池; 双向DC-DC; 充放电控制; 电流环控制; 电压环控制; MATLAB Simulink仿真模型; 电池组; 模型参数; 电压等级可调; 电流闭环; 电压闭环,Matlab Simulink仿真模型:全钒液流电池双闭环充放电控制储能系统
windows平台mysql版本安装包 mysql-installer-community
分享课程——BEV模型部署全栈教程(3D检测+车道线+Occ)课程
基于FPGA流水线结构并行FFT的设计与实现-王英喆.caj
内核驱动开发,调试监控IRP请求包发送接收工具
comsol三元锂离子电池模型 NCA111三元锂离子电池21700 电化学-热耦合模型 老化模型 容量衰减模型 参数已经设置好 自己更改参数即可进行使用学习 可进行多倍率充放电仿真 有对应参考文献 A17 ,comsol模型;三元锂离子电池;NCA111电池;电化学-热耦合模型;老化模型;容量衰减模型;参数设置;仿真学习;参考文献,COMSOL三元锂离子电池模型与NCA111电池仿真研究
野火征途Pro FPGA开发板 实现基于帧差法的运动目标检测与跟踪 摄像头:OV5640 显示屏:TFT LCD,VGA,HDMI ,野火征途Pro; FPGA开发板; 帧差法; 运动目标检测与跟踪; OV5640摄像头; TFT LCD; VGA; HDMI,野火征途Pro FPGA开发板:运动目标检测与跟踪的视觉处理
基于PLC控制的自动洗车系统 采用s7-1200设计 lunwenPPT都有 博图仿真 ,基于PLC控制; 自动洗车系统; S7-1200设计; LunwenPPT; 博图仿真,基于S7-1200 PLC控制的自动洗车系统设计与仿真
基于Springboot网吧管理系统【源码+数据库+运行文档】 后端技术栈:SpringBoot ,SpringBoot就是SSM项目的升级版,后端语言Java 前端技术栈:Vue,前端底层都是HTML+JavaScript 数据库:MySQL是目前企业最流行的数据库 SpringBoot通过“约定优于配置”自动化处理繁琐设置,内置Tomcat等服务器实现快速部署,提供Starter POMs简化依赖管理,集成大量开发工具与监控功能,极大提升开发效率,让开发者聚焦业务逻辑而非配置,故成为现代快速开发Web应用的首选框架。 Vue.js因轻量高效、双向数据绑定、组件化开发模式、灵活的插件生态以及细致的文档而受青睐。它通过虚拟DOM提高页面渲染性能,实现视图与数据的分离,便于团队协作和项目维护,尤其适合构建复杂的单页应用程序,在提升开发效率的同时保障用户体验。 MySQL是一款开源、免费的关系型数据库管理系统,以其高性能、高可扩展性、广泛的跨平台支持和活跃的社区著称。是 web 开发和企业应用的热门选择。