com.fr.third.jgroups.protocols

类 Locking.ClientCondition

java.lang.Object

com.fr.third.jgroups.protocols.Locking.ClientCondition

所有已实现的接口:

java.util.concurrent.locks.Condition

封闭类:

Locking

protected class Locking.ClientCondition
extends java.lang.Object
implements java.util.concurrent.locks.Condition

字段概要

字段

限定符和类型	字段和说明
protected Locking.ClientLock	lock
protected java.util.concurrent.atomic.AtomicReference<java.lang.Thread>	parker This is okay only having 1 since a client condition is 1 per lock_name, thread id combination.
protected java.util.concurrent.atomic.AtomicBoolean	signaled

构造器概要

构造器

构造器和说明
Locking.ClientCondition(Locking.ClientLock lock)

方法概要

方法

限定符和类型	方法和说明
void	await()
protected void	await(boolean throwInterrupt)
protected long	await(long nanoSeconds)
boolean	await(long time, java.util.concurrent.TimeUnit unit) Note this wait will only work correctly if the converted value is less than 292 years.
long	awaitNanos(long nanosTimeout)
void	awaitUninterruptibly()
boolean	awaitUntil(java.util.Date deadline)
void	signal()
void	signalAll()
protected void	signaled()

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

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

字段详细资料

lock

protected final Locking.ClientLock lock

signaled

protected final java.util.concurrent.atomic.AtomicBoolean signaled

parker

protected volatile java.util.concurrent.atomic.AtomicReference<java.lang.Thread> parker

This is okay only having 1 since a client condition is 1 per lock_name, thread id combination.

构造器详细资料

Locking.ClientCondition

public Locking.ClientCondition(Locking.ClientLock lock)

方法详细资料

await

public void await()
           throws java.lang.InterruptedException

指定者:

await 在接口中 java.util.concurrent.locks.Condition

抛出:

java.lang.InterruptedException

awaitUninterruptibly

public void awaitUninterruptibly()

指定者:

awaitUninterruptibly 在接口中 java.util.concurrent.locks.Condition

awaitNanos

public long awaitNanos(long nanosTimeout)
                throws java.lang.InterruptedException

指定者:

awaitNanos 在接口中 java.util.concurrent.locks.Condition

抛出:

java.lang.InterruptedException

await

public boolean await(long time,
            java.util.concurrent.TimeUnit unit)
              throws java.lang.InterruptedException

Note this wait will only work correctly if the converted value is less than 292 years. This is due to the limitation in System.nano and long values that can only store up to 292 years (22⁶³ nanoseconds).

For more information please see System.nanoTime()

指定者:

await 在接口中 java.util.concurrent.locks.Condition

抛出:

java.lang.InterruptedException

awaitUntil

public boolean awaitUntil(java.util.Date deadline)
                   throws java.lang.InterruptedException

指定者:

awaitUntil 在接口中 java.util.concurrent.locks.Condition

抛出:

java.lang.InterruptedException

await

protected void await(boolean throwInterrupt)
              throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

await

protected long await(long nanoSeconds)
              throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

signal

public void signal()

指定者:

signal 在接口中 java.util.concurrent.locks.Condition

signalAll

public void signalAll()

指定者:

signalAll 在接口中 java.util.concurrent.locks.Condition

signaled

protected void signaled()