并发专题阶段性总结3

参数指定是否立即中断任务执行，或者等等任务结束

消费者

生产者

一旦完成了任务，它就永久停在了“已完成”的状态

没有返回值

不能获取执行完的结果

不能抛出 checked Exception

call方法可以有返回值

可以声明抛出异常

配合Future 类，通过 Future 可以了解任务执行情况

为了避免垃圾回收，采用数组而非链表。同时，数组对处理器的缓存机制更加友好

数组长度2^n，通过位运算，加快定位的速度。下标采取递增的形式。不用担心index溢出的问题。index是long类型，即使100万QPS的处理速度，也需要30万年才能用完

每个生产者或者消费者线程，会先申请可以操作的元素在数组中的位置，申请到之后，直接在该位置写入或者读取数据

，RingBuffer就是一个可自定义大小的环形数组

Disruptor的默认策略

使用锁和condition来控制线程的唤醒

最低效的策略

但其对CPU的消耗最小

性能表现跟 BlockingWaitStrategy 差不多，对 CPU 的消耗也类似，但其对生产者线程的影响最

通过使用LockSupport.parkNanos(1)来实现循环等待

可以使用在低延迟系统的策略之一

性能最好，适合用于低延迟的系统

在要求极高性能且事件处理线程数小于CPU逻辑核心数的场景中，推荐使用此策略

自旋 + yield + 自定义策略

CPU资源紧缺，吞吐量和延迟并不重要的场景

fork()

join()

RecursiveAction

RecursiveTask

CountedCompleter

AC: 正在运行工作线程数减去目标并行度，高16位

TC: 总工作线程数减去目标并行度，中高16位

SS: 栈顶等待线程的版本计数和状态，中低16位

ID: 栈顶 WorkQueue 在池中的索引(poolIndex)，低16位

ForkJoinTask 提供了 isCompletedAbnormally() 方法来检查任务是否已经抛出异常

通过 ForkJoinTask 的 getException 方法获取异常

ForkJoinPool(int&nbsp;parallelism,<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ForkJoinWorkerThreadFactory&nbsp;factory,<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;UncaughtExceptionHandler&nbsp;handler,<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;mode,<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String&nbsp;workerNamePrefix)

把任务推入当前工作线程的工作队列里

join()&nbsp;可以使得线程免于被阻塞的原因——不像同名的&nbsp;Thread.join()

检查调用&nbsp;join()&nbsp;的线程是否是&nbsp;ForkJoinThread&nbsp;线程

查看任务的完成状态，如果已经完成，直接返回结果

如果任务尚未完成，但处于自己的工作队列内，则完成它

如果任务已经被其他的工作线程偷走，则窃取这个小偷的工作队列内的任务（以&nbsp;FIFO&nbsp;方式）

加密、解密、压缩、计算等一系列

一个计算圆周率至小数点一千位以下的程序

通过阻塞队列+FutureTask

内部有一个先进先出的阻塞队列，用于保存已经执行完成的Future

通过调用它的take方法或poll方法可以获取到一个已经执行完成的Future，进而通过调用Future接口实现类的get方法获取最终的结果

当需要批量提交异步任务的时候建议你使用CompletionService

CompletionService能够让异步任务的执行结果有序化

线程池隔离

thenApply()&nbsp;把前面异步任务的结果，交给后面的Function

thenCompose()用来连接两个有依赖关系的任务，结果由第二个任务返回

thenCombine:任务合并，有返回值

thenAccepetBoth:两个任务执行完成后，将结果交给thenAccepetBoth消耗，无返回值

runAfterBoth:两个任务都执行完成后，执行下一步操作（Runnable）

applyToEither:两个任务谁执行的快，就使用那一个结果，有返回值

acceptEither:&nbsp;两个任务谁执行的快，就消耗那一个结果，无返回值

runAfterEither:&nbsp;任意一个任务执行完成，进行下一步操作(Runnable)

CompletableFuture类自己也提供了anyOf()和allOf()用于支持多个CompletableFuture并行执行

以Runnable函数式接口类型为参数，没有返回结果

没有指定Executor的方法会使用ForkJoinPool.commonPool()&nbsp;作为它的线程池执行异步代码

CompletableFuture&nbsp;会使用公共的&nbsp;ForkJoinPool&nbsp;线程池，这个线程池默认创建的线程数是&nbsp;CPU&nbsp;的核数

如果指定线程池，则使用指定的线程池运行

supplyAsync&nbsp;方法Supplier函数式接口类型为参数，返回结果类型为U

Supplier&nbsp;接口的&nbsp;get()&nbsp;方法是有返回值的（会阻塞）