Overview  Package   Class  Deprecated  Index  Help 
org.codehaus.gpars
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

groovyx.gpars.dataflow.impl
[Java] Class ResizeableCountDownLatch.Sync

java.lang.Object
  java.util.concurrent.locks.AbstractOwnableSynchronizer
      java.util.concurrent.locks.AbstractQueuedSynchronizer
          groovyx.gpars.dataflow.impl.ResizeableCountDownLatch.Sync

private static final class ResizeableCountDownLatch.Sync
extends java.util.concurrent.locks.AbstractQueuedSynchronizer
Field Summary
private static long serialVersionUID

 
Constructor Summary
ResizeableCountDownLatch.Sync(int count)

 
Method Summary
void decreaseCount()

Constructs a CountDownLatch initialized with the given count.
int getCount()

void increaseCount()

int tryAcquireShared(int acquires)

boolean tryReleaseShared(int releases)

 
Methods inherited from class java.util.concurrent.locks.AbstractQueuedSynchronizer
java.util.concurrent.locks.AbstractQueuedSynchronizer#toString(), java.util.concurrent.locks.AbstractQueuedSynchronizer#acquireInterruptibly(int), java.util.concurrent.locks.AbstractQueuedSynchronizer#getQueueLength(), java.util.concurrent.locks.AbstractQueuedSynchronizer#getQueuedThreads(), java.util.concurrent.locks.AbstractQueuedSynchronizer#getWaitQueueLength(java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject), java.util.concurrent.locks.AbstractQueuedSynchronizer#getWaitingThreads(java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject), java.util.concurrent.locks.AbstractQueuedSynchronizer#hasQueuedThreads(), java.util.concurrent.locks.AbstractQueuedSynchronizer#hasWaiters(java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject), java.util.concurrent.locks.AbstractQueuedSynchronizer#isQueued(java.lang.Thread), java.util.concurrent.locks.AbstractQueuedSynchronizer#release(int), java.util.concurrent.locks.AbstractQueuedSynchronizer#acquire(int), java.util.concurrent.locks.AbstractQueuedSynchronizer#hasContended(), java.util.concurrent.locks.AbstractQueuedSynchronizer#owns(java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject), java.util.concurrent.locks.AbstractQueuedSynchronizer#tryAcquireNanos(int, long), java.util.concurrent.locks.AbstractQueuedSynchronizer#acquireShared(int), java.util.concurrent.locks.AbstractQueuedSynchronizer#acquireSharedInterruptibly(int), java.util.concurrent.locks.AbstractQueuedSynchronizer#getExclusiveQueuedThreads(), java.util.concurrent.locks.AbstractQueuedSynchronizer#getFirstQueuedThread(), java.util.concurrent.locks.AbstractQueuedSynchronizer#getSharedQueuedThreads(), java.util.concurrent.locks.AbstractQueuedSynchronizer#hasQueuedPredecessors(), java.util.concurrent.locks.AbstractQueuedSynchronizer#releaseShared(int), java.util.concurrent.locks.AbstractQueuedSynchronizer#tryAcquireSharedNanos(int, long), java.util.concurrent.locks.AbstractQueuedSynchronizer#wait(long, int), java.util.concurrent.locks.AbstractQueuedSynchronizer#wait(long), java.util.concurrent.locks.AbstractQueuedSynchronizer#wait(), java.util.concurrent.locks.AbstractQueuedSynchronizer#equals(java.lang.Object), java.util.concurrent.locks.AbstractQueuedSynchronizer#hashCode(), java.util.concurrent.locks.AbstractQueuedSynchronizer#getClass(), java.util.concurrent.locks.AbstractQueuedSynchronizer#notify(), java.util.concurrent.locks.AbstractQueuedSynchronizer#notifyAll()
 
Methods inherited from class java.util.concurrent.locks.AbstractOwnableSynchronizer
java.util.concurrent.locks.AbstractOwnableSynchronizer#wait(long, int), java.util.concurrent.locks.AbstractOwnableSynchronizer#wait(long), java.util.concurrent.locks.AbstractOwnableSynchronizer#wait(), java.util.concurrent.locks.AbstractOwnableSynchronizer#equals(java.lang.Object), java.util.concurrent.locks.AbstractOwnableSynchronizer#toString(), java.util.concurrent.locks.AbstractOwnableSynchronizer#hashCode(), java.util.concurrent.locks.AbstractOwnableSynchronizer#getClass(), java.util.concurrent.locks.AbstractOwnableSynchronizer#notify(), java.util.concurrent.locks.AbstractOwnableSynchronizer#notifyAll()
 

Field Detail

serialVersionUID

private static final long serialVersionUID

 
Constructor Detail

ResizeableCountDownLatch.Sync

ResizeableCountDownLatch.Sync(int count)

 
Method Detail

decreaseCount

public void decreaseCount()
Constructs a CountDownLatch initialized with the given count.
throws:
IllegalArgumentException if count is negative
Parameters:
count - the number of times countDown must be invoked before threads can pass through await

getCount

int getCount()

increaseCount

public void increaseCount()

tryAcquireShared

public int tryAcquireShared(int acquires)

tryReleaseShared

public boolean tryReleaseShared(int releases)

 

Copyright © 2008–2013 Václav Pech. All Rights Reserved.