Class AbstractWaitingCondition

java.lang.Object
com.conversantmedia.util.concurrent.AbstractWaitingCondition
All Implemented Interfaces:
Condition
Direct Known Subclasses:
ConcurrentStack.WaitingStackNotEmpty, ConcurrentStack.WaitingStackNotFull, DisruptorBlockingQueue.WaitingQueueNotEmpty, DisruptorBlockingQueue.WaitingQueueNotFull, MPMCBlockingQueue.WaitingQueueNotEmpty, MPMCBlockingQueue.WaitingQueueNotFull, PushPullBlockingQueue.WaitingQueueNotEmpty, PushPullBlockingQueue.WaitingQueueNotFull

public abstract class AbstractWaitingCondition extends Object implements Condition
Created by jcairns on 12/11/14.
  • Field Details

    • CACHE_LINE_REFS

      private static final int CACHE_LINE_REFS
    • MAX_WAITERS

      private static final int MAX_WAITERS
      See Also:
    • WAITER_MASK

      private static final long WAITER_MASK
      See Also:
    • WAIT_TIME

      private static final long WAIT_TIME
      See Also:
    • waitCount

      private final LongAdder waitCount
    • waiter

      private final AtomicReferenceArray<Thread> waiter
    • r1

      long r1
    • r2

      long r2
    • r3

      long r3
    • r4

      long r4
    • r5

      long r5
    • r6

      long r6
    • r7

      long r7
    • waitCache

      private long waitCache
    • c1

      long c1
    • c2

      long c2
    • c3

      long c3
    • c4

      long c4
    • c5

      long c5
    • c6

      long c6
    • c7

      long c7
    • c8

      long c8
  • Constructor Details

    • AbstractWaitingCondition

      public AbstractWaitingCondition()
  • Method Details