代码示例2.5

http://creativecommons.org/publicdomain/zero/1.0/*/package

{code

executor.execute(future);}/pre**

pMemory

hrefpackage-summary.html#MemoryVisibility

ihappen-before/i/a*

http://creativecommons.org/publicdomain/zero/1.0/*/package

{code

提供了用于检查计算是否完成、等待其完成以及检索其结果的方法。

*

只有在计算完成之后才能使用

executor.execute(future);}/pre**

hrefpackage-summary.html#MemoryVisibilityi先于happen-before/i/a*

另一个线程中随后调用

如果任务已经完成、已被取消或因其他原因无法取消则该尝试将失败。

*

如果任务已经启动则参数

如有必要最多等待指定的时间以完成计算然后如果可用检索其结果。

**

param

并发包java.util.concurrent中的一个核心接口由并发编程专家

Doug

即一个任务可能还在执行但你可以提前获取它的引用并在之后查询、等待或取消它的执行。

1.1

Executors.newSingleThreadExecutor();//

提交一个

42;});System.out.println(任务已提交等待结果...);//

阻塞等待结果Integer

http://creativecommons.org/publicdomain/zero/1.0/

import

java.util.concurrent.locks.LockSupport;/***

{link

从中间状态转换为最终状态使用的是懒加载写入比普通写入性能更好。

**

状态转换图*

完成状态码*/SuppressWarnings(unchecked)private

report(int

ExecutionException((Throwable)x);}/***

创建一个

NullPointerException();this.callable

callable;this.state

默认实现什么也不做。

子类可以覆盖此方法来添加回调或记录。

*/protected

void

(UNSAFE.compareAndSwapInt(this,

stateOffset,

NORMAL);finishCompletion();}}/***

param

(UNSAFE.compareAndSwapInt(this,

stateOffset,

EXCEPTIONAL);finishCompletion();}}public

void

||!UNSAFE.compareAndSwapObject(this,

runnerOffset,null,

Thread.currentThread()))return;try

{CallableV

INTERRUPTING)handlePossibleCancellationInterrupt(s);}}/***

boolean

||!UNSAFE.compareAndSwapObject(this,

runnerOffset,null,

INTERRUPTING)handlePossibleCancellationInterrupt(s);}return

ran

handlePossibleCancellationInterrupt(int

{if

(UNSAFE.compareAndSwapObject(this,

waitersOffset,

null;LockSupport.unpark(t);}WaitNode

next

UNSAFE.compareAndSwapObject(this,

waitersOffset,q.next

state;}LockSupport.parkNanos(this,

nanos);}elseLockSupport.park(this);}}/***

void

(!UNSAFE.compareAndSwapObject(this,

waitersOffset,q,

sun.misc.Unsafe.getUnsafe();Class?

UNSAFE.objectFieldOffset(k.getDeclaredField(state));runnerOffset

UNSAFE.objectFieldOffset(k.getDeclaredField(runner));waitersOffset

UNSAFE.objectFieldOffset(k.getDeclaredField(waiters));}

catch

Runnable可被线程执行FutureV可获取结果、支持取消

作用简述

提交异步任务执行等待任务完成并获取结果支持任务取消、中断支持异常处理

2.1

get()方法是阻塞方法一旦调用get方法求结果如果没有计算完容易导致程序阻塞。

Future获取的结果不是很好只能通过阻塞或者轮训的方式获取到任务的结果。

2.6

https://www.bilibili.com/video/BV1ar4y1x727?spm_id_from333.788.player.switchvd_source240d9002f7c7e3da63cd9a975639409ap14