com.fr.third.jgroups.blocks.executor

类 ExecutionService.DistributedFuture.Sync<V>

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

com.fr.third.jgroups.blocks.executor.ExecutionService.DistributedFuture.Sync<V>

所有已实现的接口:

java.io.Serializable

封闭类:

ExecutionService.DistributedFuture<V>

protected static final class ExecutionService.DistributedFuture.Sync<V>
extends java.util.concurrent.locks.AbstractQueuedSynchronizer

Synchronization control for FutureTask. Note that this must be a non-static inner class in order to invoke the protected done method. For clarity, all inner class support methods are same as outer, prefixed with "inner".

Uses AQS sync state to represent run status

另请参阅:

序列化表格

嵌套类概要

从类继承的嵌套类/接口 java.util.concurrent.locks.AbstractQueuedSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer.ConditionObject

字段概要

字段

限定符和类型	字段和说明
protected java.util.concurrent.Callable<V>	callable The underlying callable
protected static int	CANCELLED State value representing that task was cancelled
protected java.lang.Throwable	exception The exception to throw from get()
protected ExecutionService.DistributedFuture<V>	future The containing future
protected static int	RAN State value representing that task ran
protected V	result The result to return from get()
protected java.lang.Thread	runner The thread running task.
protected static int	RUNNING State value representing that task is running

构造器概要

构造器

构造器和说明
ExecutionService.DistributedFuture.Sync(ExecutionService.DistributedFuture<V> future, java.util.concurrent.Callable<V> callable)

方法概要

方法

限定符和类型	方法和说明
protected int	tryAcquireShared(int ignore) Implements AQS base acquire to succeed if ran or cancelled
protected boolean	tryReleaseShared(int ignore) Implements AQS base release to always signal after setting final done status by nulling runner thread.

从类继承的方法 java.util.concurrent.locks.AbstractQueuedSynchronizer

acquire, acquireInterruptibly, acquireShared, acquireSharedInterruptibly, compareAndSetState, getExclusiveQueuedThreads, getFirstQueuedThread, getQueuedThreads, getQueueLength, getSharedQueuedThreads, getState, getWaitingThreads, getWaitQueueLength, hasContended, hasQueuedPredecessors, hasQueuedThreads, hasWaiters, isHeldExclusively, isQueued, owns, release, releaseShared, setState, toString, tryAcquire, tryAcquireNanos, tryAcquireSharedNanos, tryRelease

从类继承的方法 java.util.concurrent.locks.AbstractOwnableSynchronizer

getExclusiveOwnerThread, setExclusiveOwnerThread

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

字段详细资料

RUNNING

protected static final int RUNNING

State value representing that task is running

另请参阅:

常量字段值

RAN

protected static final int RAN

State value representing that task ran

另请参阅:

常量字段值

CANCELLED

protected static final int CANCELLED

State value representing that task was cancelled

另请参阅:

常量字段值

future

protected final ExecutionService.DistributedFuture<V> future

The containing future

callable

protected final java.util.concurrent.Callable<V> callable

The underlying callable

result

protected V result

The result to return from get()

exception

protected java.lang.Throwable exception

The exception to throw from get()

runner

protected transient volatile java.lang.Thread runner

The thread running task. When nulled after set/cancel, this indicates that the results are accessible. Must be volatile, to ensure visibility upon completion.

构造器详细资料

ExecutionService.DistributedFuture.Sync

public ExecutionService.DistributedFuture.Sync(ExecutionService.DistributedFuture<V> future,
                                       java.util.concurrent.Callable<V> callable)

方法详细资料

tryAcquireShared

protected int tryAcquireShared(int ignore)

Implements AQS base acquire to succeed if ran or cancelled

覆盖:

tryAcquireShared 在类中 java.util.concurrent.locks.AbstractQueuedSynchronizer

tryReleaseShared

protected boolean tryReleaseShared(int ignore)

Implements AQS base release to always signal after setting final done status by nulling runner thread.

覆盖:

tryReleaseShared 在类中 java.util.concurrent.locks.AbstractQueuedSynchronizer