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

开发者 · 2024-9-10 00:22:32

思想：分而治之
用来做什么

ForkJoinPool是ExecutorService接口的实现，它专为可以递归分解成小块的工作而设计。fork / join框架将任务分配给线程池中的工作线程，充分利用多处理器的优势，提高程序性能。使用fork / join框架的第一步是编写执行一部分工作的代码。类似的伪代码如下:

如果（当前工作部分足够小)
直接做这项工作
其他
把当前工作分成两部分调用这两个部分并等待结果

将此代码包装在ForkJoinTask子类中，通常是RecursiveTask (可以返回结果)或RecursiveAction.
先来看一个例子，下边的例子是模拟读取一个大文件的过程，使用了java多线程中的Callable方式，每个线程最多读取10个，这样的多线程一起读取的方式来提升效率的。

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

所属分类: 问答交流

新帖推荐: 30日

推荐作品