Java并发 - fork/join并发处理框架

开发者 2024-9-10 00:22:32 78 0 来自 中国
思想:分而治之
用来做什么

ForkJoinPool是ExecutorService接口的实现,它专为可以递归分解成小块的工作而设计。fork / join框架将任务分配给线程池中的工作线程,充分利用多处理器的优势,提高程序性能。使用fork / join框架的第一步是编写执行一部分工作的代码。类似的伪代码如下:
如果(当前工作部分足够小)
直接做这项工作
其他
把当前工作分成两部分调用这两个部分并等待结果
将此代码包装在ForkJoinTask子类中,通常是RecursiveTask (可以返回结果)或RecursiveAction.
先来看一个例子,下边的例子是模拟读取一个大文件的过程,使用了java多线程中的Callable方式,每个线程最多读取10个,这样的多线程一起读取的方式来提升效率的。
您需要登录后才可以回帖 登录 | 立即注册

Powered by CangBaoKu v1.0 小黑屋藏宝库It社区( 冀ICP备14008649号 )

GMT+8, 2024-11-23 19:26, Processed in 0.156247 second(s), 33 queries.© 2003-2025 cbk Team.

快速回复 返回顶部 返回列表