Fork-Join

1.分而治之

将一个大任务，进行拆分（Fork）成若干个小任务（到不可拆分时），再将一个个小任务运算的结果进行join汇总。 工作密取 workStealing使用标准范式 ForkJoinPool pool = new ForkJoinPool(); MyTask myTask = new ForkJoinTask(); Pool.invoke(myTask); Result = myTask.join();

MyTask extends RecursiveTask/RecusiveAction/ForkJoinTask

4.Fork-Join实战

Fork-Join的同步方法返回结果值：统计整形数组中所有元素的和 pool.invoke(task) Fork-Join的异步方法不要求返回结果只：遍历指定目录（含子目录）寻找指定类型文件 pool.execute(task)

常用的并发工具类

CountDownLatch

作用：是一组线程等待其它线程完成工作以后再执行，加强版的join() await用来等待，countDown负责计数器减一

CyclicBarrier

作用：让一组线程到达某个屏障，被阻塞，一直到组内最后一个线程到达屏障时，屏障开放，所有被阻塞的线程会继续运行 CyclicBarrier(int partier) CyclicBarrier(int partier , Runnable barrierAction) , 屏障开放，barrierAction定义的任务会执行

CountDownLatch 和 CyclicBarrier辨析

countDownLatch放行由第三者控制，CyclicBarrier放行由一组线程本身控制countDownLatch放行条件 >= 线程数 cyclicBarrier放行条件 = 线程数

Semaphore

控制同时访问某个特定资源的线程数量，用在流量控制

Exchange

线程间的数据交换

Callable、Future和FutureTask

isDone：结束，正常还是异常结束，或者自己取消，返回true； isCancelled： 任务完成前被取消，返回true； cancel(boolean)：1.任务还没开始，返回false；2.任务已经启动，>cancel(true)，中断正在运行的任务，中断成功，返回true；cancel(false)，不>去中断已经运行的任务；3. 任务已经结束，返回false