26. ForkJoin:单机版的MapReduce - 并发工具类
本文共 2510 字,大约阅读时间需要 8 分钟。
???????ForkJoin??
??????
????????????????????????????????????????????????????????????????????????????
?????????????????????????????????????? ?????????????????????????????? Fork/Join???
Fork/Join???Java???????????????????????????????????????
- Fork?????????fork()????????????????????
- Join?????????join()?????????????????
ForkJoin?????????????
ForkJoinPool????????????????ForkJoin??????????????????????????? ForkJoinTask??????????????????????????? - fork()??????????
- join()??????????????
ForkJoinTask????????
RecursiveAction????????????????????????? RecursiveTask???????????????????????? ForkJoinPool????
ForkJoinPool??????????-???????????????????????ForkJoinPool????????????????????????????????????????????????????????????????
ForkJoinPool??????????????????????????????????
??MapReduce??????
MapReduce???????????????????????????MapReduce??????????
public class MyTest2 { public static void main(String[] args) { String[] fc = { "hello world", "hello me", "hello fork", "hello join", "fork join in world" }; ForkJoinPool fjp = new ForkJoinPool(3); MR mr = new MR(fc, 0, fc.length); Map result = fjp.invoke(mr); result.forEach((k, v) -> System.out.println(k + ":" + v)); } static class MR extends RecursiveTask
??????MR
???????????????????????ForkJoin?????????????????????????????????
转载地址:http://hihwz.baihongyu.com/