JDK 7 中的 Fork/Join 模式
作者:xunchangguo 日期:2007-08-31 21:45:55
随着多核时代的来临,软件开发人员不得不开始关注并行编程领域。而 JDK 7 中将会加入的 Fork/Join 模式是处理并行编程的一个经典的方法。虽然不能解决所有的问题,但是在它的适用范围之内,能够轻松的利用多个 CPU 提供的计算资源来协作完成一个复杂的计算任务。通过利用 Fork/Join 模式,我们能够更加顺畅的过渡到多核的时代。本文将介绍使用 JDK 7 中 Fork/Join 模式的方法和其他相关改进。阅读本文之后,读者将能够独立地在软件开发中使用 Fork/Join 模式来改进程序的性能。<!--START RESERVED FOR FUTURE USE INCLUDE FILES--><!-- include java script once we verify teams wants to use this and it will work on dbcs and cyrillic characters --><!--END RESERVED FOR FUTURE USE INCLUDE FILES-->
随着多核芯片逐渐成为主流,大多数软件开发人员不可避免地需要了解并行编程的知识。而同时,主流程序语言正在将越来越多的并行特性合并到标准库或者语言本身之中。我们可以看到,JDK 在这方面同样走在潮流的前方。在 JDK 标准版 5 中,由 Doug Lea 提供的并行框架成为了标准库的一部分(JSR-166)。随后,在 JDK 6 中,一些新的并行特性,例如并行 collection 框架,合并到了标准库中(JSR-166x)。直到今天,尽管 Java SE 7 还没有正式发布,一些并行相关的新特性已经出现在 JSR-166y 中:
- Fork/Join 模式;
- TransferQueue,它继承自 BlockingQueue 并能在队列满时阻塞“生产者”;
- ArrayTasks/ListTasks,用于并行执行某些数组/列表相关任务的类;
- IntTasks/LongTasks/DoubleTasks,用于并行处理数字类型数组的工具类,提供了排序、查找、求和、求最小值、求最大值等功能;
其中,对 Fork/Join 模式的支持可能是对开发并行软件来说最通用的新特性。在 JSR-166y 中,Doug Lea 实现 ArrayTasks/ListTasks/IntTasks/LongTasks/DoubleTasks 时就大量的用到了 Fork/Join 模式。读者还需要注意一点,因为 JDK 7 还没有正式发布,因此本文涉及到的功能和发布版本有可能不一样。
Fork/Join 模式有自己的适用范围。如果一个应用能被分解成多个子任务,并且组合多个子任务的结果就能够获得最终的答案,那么这个应用就适合用 Fork/Join 模式来解决。图 1 给出了一个 Fork/Join 模式的示意图,位于图上部的 Task 依赖于位于其下的 Task 的执行,只有当所有的子任务都完成之后,调用者才能获得 Task 0 的返回结果。
图 1. Fork/Join 模式示意图
可以说,Fork/Join 模式能够解决很多种类的并行问题。通过使用 Doug Lea 提供的 Fork/Join 框架,软件开发人员只需要关注任务的划分和中间结果的组合就能充分利用并行平台的优良性能。其他和并行相关的诸多难于处理的问题,例如负载平衡、同步等,都可以由框架采用统一的方式解决。这样,我们就能够轻松地获得并行的好处而避免了并行编程的困难且容易出错的缺点。
在开始尝试 Fork/Join 模式之前,我们需要从 Doug Lea 主持的 Concurrency JSR-166 Interest Site 上下载 JSR-166y 的源代码,并且我们还需要安装最新版本的 JDK 6(下载网址请参阅 参考资源)。Fork/Join 模式的使用方式非常直观。首先,我们需要编写一个 ForkJoinTask 来完成子任务的分割、中间结果的合并等工作。随后,我们将这个 ForkJoinTask 交给 ForkJoinPool 来完成应用的执行。
通常我们并不直接继承 ForkJoinTask,它包含了太多的抽象方法。针对特定的问题,我们可以选择 ForkJoinTask 的不同子类来完成任务。RecursiveAction 是 ForkJoinTask 的一个子类,它代表了一类最简单的 ForkJoinTask:不需要返回值,当子任务都执行完毕之后,不需要进行中间结果的组合。如果我们从 RecursiveAction 开始继承,那么我们只需要重载 protected void compute() 方法。下面,我们来看看怎么为快速排序算法建立一个 ForkJoinTask 的子类:
清单 1. ForkJoinTask 的子类
class SortTask extends RecursiveAction { |
在 清单 1 中,SortTask 首先通过 partition() 方法将数组分成两个部分。随后,两个子任务将被生成并分别排序数组的两个部分。当子任务足够小时,再将其分割为更小的任务反而引起性能的降低。因此,这里我们使用一个 THRESHOLD,限定在子任务规模较小时,使用直接排序,而不是再将其分割成为更小的任务。其中,我们用到了 RecursiveAction 提供的方法 coInvoke()。它表示:启动所有的任务,并在所有任务都正常结束后返回。如果其中一个任务出现异常,则其它所有的任务都取消。coInvoke() 的参数还可以是任务的数组。
现在剩下的工作就是将 SortTask 提交到 ForkJoinPool 了。ForkJoinPool() 默认建立具有与 CPU 可使用线程数相等线程个数的线程池。我们在一个 JUnit 的 test 方法中将 SortTask 提交给一个新建的 ForkJoinPool:
清单 2. 新建的 ForkJoinPool
@Test |
在上面的代码中,我们用到了 ForkJoinPool 提供的如下函数:
submit():将 ForkJoinTask 类的对象提交给 ForkJoinPool,ForkJoinPool 将立刻开始执行 ForkJoinTask。shutdown():执行此方法之后,ForkJoinPool 不再接受新的任务,但是已经提交的任务可以继续执行。如果希望立刻停止所有的任务,可以尝试shutdownNow()方法。awaitTermination():阻塞当前线程直到 ForkJoinPool 中所有的任务都执行结束。
并行快速排序的完整代码如下所示:
清单 3. 并行快速排序的完整代码
package tests; |
运行以上代码,我们可以得到以下结果:
Initial Array: [46, -12, 74, -67, 76, -13, -91, -96] |
除了 RecursiveAction,Fork/Join 框架还提供了其他 ForkJoinTask 子类:带有返回值的 RecursiveTask,使用 finish() 方法显式中止的 AsyncAction 和 LinkedAsyncAction,以及可使用 TaskBarrier 为每个任务设置不同中止条件的 CyclicAction。
从 RecursiveTask 继承的子类同样需要重载 protected void compute() 方法。与 RecursiveAction 稍有不同的是,它可使用泛型指定一个返回值的类型。下面,我们来看看如何使用 RecursiveTask 的子类。
清单 4. RecursiveTask 的子类
class Fibonacci extends RecursiveTask<Integer> { |
在 清单 4 中, Fibonacci 的返回值为 Integer 类型。其 compute() 函数首先建立两个子任务,启动子任务执行,阻塞以等待子任务的结果返回,相加后得到最终结果。同样,当子任务足够小时,通过查表得到其结果,以减小因过多地分割任务引起的性能降低。其中,我们用到了 RecursiveTask 提供的方法 fork() 和 join()。它们分别表示:子任务的异步执行和阻塞等待结果完成。
现在剩下的工作就是将 Fibonacci 提交到 ForkJoinPool 了,我们在一个 JUnit 的 test 方法中作了如下处理:
清单 5. 将 Fibonacci 提交到 ForkJoinPool
@Test |
CyclicAction 的用法稍微复杂一些。如果一个复杂任务需要几个线程协作完成,并且线程之间需要在某个点等待所有其他线程到达,那么我们就能方便的用 CyclicAction 和 TaskBarrier 来完成。图 2 描述了使用 CyclicAction 和 TaskBarrier 的一个典型场景。
图 2. 使用 CyclicAction 和 TaskBarrier 执行多线程任务
继承自 CyclicAction 的子类需要 TaskBarrier 为每个任务设置不同的中止条件。从 CyclicAction 继承的子类需要重载 protected void compute() 方法,定义在 barrier 的每个步骤需要执行的动作。compute() 方法将被反复执行直到 barrier 的 isTerminated() 方法返回 True。TaskBarrier 的行为类似于 CyclicBarrier。下面,我们来看看如何使用 CyclicAction 的子类。
清单 6. 使用 CyclicAction 的子类
class ConcurrentPrint extends RecursiveAction { |
在 清单 6 中,CyclicAction[] 数组建立了三个任务,打印各自的工作次数和序号。而在 b.terminate() 方法中,我们设置的中止条件表示重复 10 次计算后中止。现在剩下的工作就是将 ConcurrentPrint 提交到 ForkJoinPool 了。我们可以在 ForkJoinPool 的构造函数中指定需要的线程数目,例如 ForkJoinPool(4) 就表明线程池包含 4 个线程。我们在一个 JUnit 的 test 方法中运行 ConcurrentPrint 的这个循环任务:
清单 7. 运行 ConcurrentPrint 循环任务
@Test |
RecursiveTask 和 CyclicAction 两个例子的完整代码如下所示:
清单 8. RecursiveTask 和 CyclicAction 两个例子的完整代码
package tests; |
运行以上代码,我们可以得到以下结果:
testing Task Barrier ... |
从以上的例子中可以看到,通过使用 Fork/Join 模式,软件开发人员能够方便地利用多核平台的计算能力。尽管还没有做到对软件开发人员完全透明,Fork/Join 模式已经极大地简化了编写并发程序的琐碎工作。对于符合 Fork/Join 模式的应用,软件开发人员不再需要处理各种并行相关事务,例如同步、通信等,以难以调试而闻名的死锁和 data race 等错误也就不会出现,提升了思考问题的层次。你可以把 Fork/Join 模式看作并行版本的 Divide and Conquer 策略,仅仅关注如何划分任务和组合中间结果,将剩下的事情丢给 Fork/Join 框架。
在实际工作中利用 Fork/Join 模式,可以充分享受多核平台为应用带来的免费午餐。
学习
- 阅读文章“The Free Lunch Is Over: A Fundamental Turn Toward Concurrency in Software”:了解为什么从现在开始每个严肃的软件工作者都应该了解并行编程方法。
- 阅读 Doug Lea 的文章“A Java Fork/Join Framework”:了解 Fork/Join 模式的实现机制和执行性能。
- 阅读 developerWorks 文章“驯服 Tiger:并发集合”:了解如何使用并行 Collection 库。
- 阅读 developerWorks 文章“Java 理论与实践:非阻塞算法简介”:介绍了 JDK 5 在并行方面的重要增强以及在 JDK5 平台上如何实现非阻塞算法的一般介绍。
- 书籍“Java Concurrency in Practice”:介绍了大量的并行编程技巧、反模式、可行的解决方案等,它对于 JDK 5 中的新特性也有详尽的介绍。
- 共有 13 条评论
- 共有 13 条评论
订阅
上一篇
|

文章来自:
标签: 
twelve sky gold
12sky power leveling
2moons dil
2moons gold
2moons power leveling
9dragons gold
9dragons power leveling
age of conan gold
age of conan power leveling
archlord gold
archlord online gold
cabal alz
cabal gold
cable power leveling
dekaron gold
dekaron dil
dofus kamas
dofus gold
fiesta gold
fiesta online gold
hero gold
hero online gold
knight online gold
knight gold
knight noah
maplestory gold
maplestory mesos
requiem gold
requiem lant
rohan crone
rohan gold
runescape gold
rs gold
runescape money
shaiya online
shaiya gold
shaiya money
shaiya power leveling
silkroad online gold
silkroad gold
sro online gold
sro gold
scions of fate
scions of fate gold
sof gold
sof power leveling
scions of fate power leveling
vanguard gold
wanguard power leveling
wow gold
wow gold tips
wow gold guide
world of warcraft gold
buy wow gold
cheap wow gold
wow power leveling
wow gold
wow gold
wow gold
wow gold
wow gold
wow gold
World of Warcraft Gold
cheap wow gold
buy wow gold
buy cheap wow gold
wow gold price
wow gold guide
wow gold farming
gold wow gold
wow gold buy wow gold
wow gold com
wow gold forum
wow gold reviews
wow gold paypal
world of warcraft gold
wow gold credit card
wow gold sale
wow gold cheap
buying wow gold
buy gold for wow
gold wow
sell wow gold
wow gold eu
wow gold us
cheapest wow gold
www wow gold
sell wow gold us
errerer567
wow gold
wow gold
ycthtaiq
wow gold
wow gold
wow gold
wow gold
World of Warcraft Gold
cheap wow gold
buy wow gold
gold wow
sell wow gold
wow gold eu
wow gold us
cheapest wow gold
buy cheap wow gold
wow gold price
wow gold guide
wow gold farming
wow gold reviews
wow gold paypal
world of warcraft gold
wow gold credit card
wow gold sale
wow gold cheap
buying wow gold
buy gold for wow
gold wow gold
wow gold buy wow gold
wow gold com
wow gold forum
www wow gold
sell wow gold us
Cheap Warhammer gold
Warhammer Online gold
WAR Gold
Buy Warhammer Gold
Warhammer Online Gold
Warhammer Gold for sale
Warhammer Accounts
Buy Warhammer Accounts
Cheap Warhammer Accounts
Warhammer Power leveling
WAR Power leveling
Warhammer Online Power Leveling
Warhammer CD Key
WAR CD Key
Warhammer Online CD Key
Warhammer Game Time Card
wow gold
rolex
wow power leveling
wow power leveling
wow power leveling
wow power leveling
wow power leveling
wow power leveling
wow gold
wow gold
光盘刻录
租房
租房
北京租房
北京租房
google排名
lotro gold
翻译公司
翻译公司
marysijia000011
打折机票
走进鸟巢,走进国家体育场!2008北京奥运,让我们瞩目你那崭新的容貌,让我们扑向你热情的怀抱,让我们聆听你最有力的心声,让我们一起迎接这些开在千年古都的奇葩吧!
marysijia000011上海搬家
搬家公司
上海搬家公司
上海搬场公司
上海搬场
搬场公司
打折机票
国际机票
特价机票
上海机票
飞机票
上海中铁
货运公司
北京奥运会,我们都准备好了!距离北京奥运会只剩下不足1个月的时间了,让我们走进北京,感受北京日新月异的城市快速发展。
chloe_hb159@hotmail.com
chloe@21cnmanager.com
Age of Conan Gold
AoC Gold
Sell Age of Conan Gold
Age of Conan News
Age of Conan Gold
Buy Age of Conan Gold
Age of Conan Gold
Buy Age of Conan Gold
Buy Cheap Age of Conan Gold
Age of Conan Power Leveling
cheap Age of Conan power leveling
sell Age of Conan Power Leveling
Age of Conan Accounts
Age of Conan Accounts for sale
AoC Accounts
Cheap wow gold
buy wow gold
cheapest wow gold
world of warcraft gold
sell world of warcraft gold
buy wow account
buy world of warcraft account
wow power leveling
world of warcraft powerleveling
Wow Honor Points Leveling
Wow Pvp Honor Leveling
wow profession leveling
wow skill leveling
Wow Reputation Leveling
World Of Warcraft Reputation Leveling
Wow Honor Leveling
World Of Warcraft Honor Leveling
Wow Cd Key
wow Game Time Card
Wow gold for sale
wow gold fast delivery
wow accounts
buy wow account character
cheap wow power leveling
world of warcraft powerleveling
World Of Warcraft Cd Key
World Of Warcraft Time Card
Buy Lotro Gold | Lord Of The Rings Online Gold
Lotro Accounts | Buy Lotro Accounts
Lord Of The Rings Online Power Leveling | Lord Of The Rings Online PowerLeveling
Lotro Cd Key | Lord Time Card
Lotro Gold | Lotro Gold Instant Delivery
lord of the rings online accounts | lord of the rings online accounts for sale
Lotro Power Leveling | Lotro Powerleveling
Lord Of The Rings Online Cd Key | Lord Of The Rings Online Time Card
l2 adena | lineage2 adena
lineage 2 accounts | l2 accounts
lineage 2 power leveling
lineage 2 powerleveling
l2 power leveling | lineage 2 Cd key
L2 Cd Key | lineage 2 time card
l2 game time card
World of Warcraft Gold
Lineage 2 Adena
L2 Adena
Lineage2 Adena
Lineage 2 Adena for sale
Lineage 2 Accounts
L2 Accounts
Lineage 2 Accounts
Lineage 2 Power Leveling
Lineage 2 CD Key
Cheap WoW Gold
Buy WoW Gold
WoW Accounts
WoW Power Leveling
World of Warcraft Power Leveling
WoW CD Key
WOW Gold Europe
WoW EU Gold
WoW Accounts For Sale
World of Warcraft CD Key
LoTRO Gold
Lord of the Rings Online Gold
Buy Lotro Gold
Sell LoTRO Gold
LoTRO CD Key
LoTRO Europe Gold
Cheap LoTRO Accounts
Lord of the Rings Online Power Leveling
Lord of the Rings online CD Key
Cheap Lotro Gold
Cheap Lineage 2 Adena
Buy Lineage 2 Adena
World of Warcraft Gold
Cheap WoW Gold
World of Warcraft Europe Gold
WoW Gold Europe
LoTR Gold
LoTRO EU Gold
Lord of the Rings Online EU Gold
buy wow gold
cheapest wow gold
world of warcraft gold
sell world of warcraft gold
buy wow account
buy world of warcraft account
wow power leveling
world of warcraft powerleveling
Wow Honor Points Leveling
Wow Pvp Honor Leveling
wow profession leveling
wow skill leveling
Wow Reputation Leveling
World Of Warcraft Reputation Leveling
Wow Honor Leveling
World Of Warcraft Honor Leveling
Wow Cd Key
wow Game Time Card
Wow gold for sale
wow gold fast delivery
wow accounts
buy wow account character
cheap wow power leveling
world of warcraft powerleveling
World Of Warcraft Cd Key
World Of Warcraft Time Card
Buy Lotro Gold | Lord Of The Rings Online Gold
Lotro Accounts
| Buy Lotro Accounts
Lord Of The Rings Online Power Leveling | Lord Of The Rings Online PowerLeveling
Lotro Cd Key | Lord Time Card
Lotro Gold | Lotro Gold Instant Delivery
lord of the rings online accounts | lord of the rings online accounts for sale
Lotro Power Leveling | Lotro Powerleveling
Lord Of The Rings Online Cd Key | Lord Of The Rings Online Time Card
cheap wow gold
buy wow gold
l2 adena
lineage2 adena
lineage 2 accounts
l2 accounts
lineage 2 power leveling
lineage 2 powerleveling l2 power leveling
lineage 2 Cd key
L2 Cd Key
lineage 2 time card
l2 game time card
l2 adena
wow gold
world of warcraft gold
lotro gold
lord of the rings online gold
sijiawmy8
上海搬家公司
上海搬场公司
搬场公司
搬家公司
上海搬家
上海搬场
sijiawmy8
上海物流
上海物流公司
物流公司
上海货运
上海货运公司
货运公司
sijiawmy8
飞机票
国际机票
上海机票
特价机票
打折机票