。

具体来说是这样的#xff1a;当我们执行某一耗时的任务时#xff0c;可以将这个耗时任…1.

Future

类是异步思想的典型运用主要用在一些需要执行耗时任务的场景避免程序一直原地等待耗时任务执行完成执行效率太低。

具体来说是这样的当我们执行某一耗时的任务时可以将这个耗时任务交给一个子线程去异步执行同时我们可以干点其他事情不用傻傻等待耗时任务执行完成。

等我们的事情干完后我们再通过

Future

类获取到耗时任务的执行结果。

这样一来程序的执行效率就明显提高了。

Future

模式你可以将其看作是一种设计模式核心思想是异步调用主要用在多线程领域并非

Java

取消任务判断任务是否被取消;判断任务是否已经执行完成;获取任务执行结果。

public

TimeoutExceptio}简单理解就是我有一个任务提交给了

Future

来处理。

任务执行期间我自己可以去做任何想做的事情。

并且在这期间我还可以取消任务以及获取任务的执行状态。

一段时间之后我就可以

Future

Runnable具有取消任务、查看任务是否执行完成以及获取任务执行结果的方法。

ExecutorService.submit()

Future

NullPointerException();this.callable

callable;this.state

通过适配器RunnableAdapter来将Runnable对象runnable转换成Callable对象this.callable

result);this.state

在实际使用过程中存在一些局限性比如不支持异步任务的编排组合、获取计算结果的

get()

特性之外还提供了函数式编程、异步任务编排组合可以将多个异步任务串联起来组成一个完整的链式调用等能力。

下面我们来简单看看

接口描述了一个异步计算的阶段。

很多计算可以分成多个阶段或步骤此时可以通过它将所有步骤组合起来形成异步计算的流水线。

CompletionStage

的函数式能力就是这个接口赋予的。

从这个接口的方法参数你就可以发现其大量使用了

Java8

ReentrantReadWriteLockSynchronousQueue等等皆是基于

AQS

核心思想是如果被请求的共享资源空闲则将当前请求资源的线程设置为有效的工作线程并且将共享资源设置为锁定状态。

如果被请求的共享资源被占用那么就需要一套线程阻塞等待以及被唤醒时锁分配的机制这个机制

AQS

队列是一个虚拟的双向队列虚拟的双向队列即不存在队列实例仅存在结点之间的关联关系。

AQS

同步队列中一个节点表示一个线程它保存着线程的引用thread、

当前节点在队列中的状态waitStatus、前驱节点prev、后继节点next。

AQS

类型的getState()、setState()和compareAndSetState()

final

//原子地CAS操作将同步状态值设置为给定值update如果当前同步状态的值等于expect期望值

protected

state0即释放锁为止其它线程才有机会获取该锁。

当然释放锁之前A

会累加这就是可重入的概念。

但要注意获取多少次就要释放多少次这样才能保证

state

都是一次只允许一个线程访问某个资源而Semaphore(信号量)可以用来控制同时访问特定资源的线程数量。

Semaphore

个线程能获取到共享资源其他线程都会阻塞只有获取到共享资源的线程才能执行。

等到有线程释放了共享资源其他阻塞的线程才能获取到。

初始共享资源数量

通常用于那些资源有明确访问数量限制的场景比如限流仅限于单机模式实际项目中推荐使用

Redis

{sync.acquireSharedInterruptibly(1);

/***

共享模式下获取许可证获取成功则返回失败则加入阻塞队列挂起线程*/

public

尝试获取许可证arg为获取许可证个数当可用许可证数减当前获取的许可证数结果小于0,则创建一个节点加入阻塞队列挂起当前线程。

if

0)doAcquireSharedInterruptibly(arg);

CAS

statestate1。

释放许可证成功之后同时会唤醒同步队列中的一个线程。

被唤醒的线程会重新尝试去修改

state

{//唤醒同步队列中的一个线程doReleaseShared();return

true;}return

是一次性的计数器的值只能在构造方法中初始化一次之后没有任何机制再次对其设置值当

CountDownLatch

0或者调用await()的线程被中断该线程才会从阻塞中被唤醒await()

2.3.3

个任务都是没有执行顺序依赖的任务但是我们需要返回给用户的时候将这几个文件的处理的结果进行统计整理。

处理思路

await()方法直到所有文件读取完之后才会接着执行后面的逻辑。

伪代码如下

创建一个具有固定线程数量的线程池对象推荐使用构造方法创建ExecutorService

threadPool

Executors.newFixedThreadPool(10);final

CountDownLatch

CountDownLatch(threadCount);for

(int

{//表示一个文件已经被完成countDownLatch.countDown();}});}countDownLatch.await();threadPool.shutdown();System.out.println(finish);}

}2.4

的字面意思是可循环使用Cyclic的屏障Barrier。

它要做的事情是让一组线程到达一个屏障也可以叫同步点时被阻塞直到最后一个线程到达屏障时屏障才会开门所有被屏障拦截的线程才会继续干活。

2.4.2

了表示这是这一代最后一个线程到达栅栏就尝试执行我们构造方法中输入的任务。

private

IllegalArgumentException();this.parties

parties;this.count

就代表了有拦截的线程的数量当拦截的线程数量达到这个值的时候就打开栅栏让所有线程通过。

2、当调用

方法就像树立起一个栅栏的行为一样将线程挡住了当拦住的线程数量达到

parties

BrokenBarrierException,TimeoutException

{final

之后说明最后一个线程已经到达栅栏了也就是达到了可以执行await

(index

(!ranAction)breakBarrier();}}//

loop

execution.Thread.currentThread().interrupt();}}if

(g.broken)throw