Package org.apache.cassandra.utils.concurrent

Class OpOrder.Group

java.lang.Object
org.apache.cassandra.utils.concurrent.OpOrder.Group
All Implemented Interfaces:
AutoCloseable, Comparable<OpOrder.Group>
Enclosing class:
OpOrder
public static final class OpOrder.Group extends Object implements Comparable<OpOrder.Group>, AutoCloseable
Represents a group of identically ordered operations, i.e. all operations started in the interval between two barrier issuances. For each register() call this is returned, close() must be called exactly once. It should be treated like taking a lock().

  • Method Details

    • close

      public void close()
      To be called exactly once for each register() call this object is returned for, indicating the operation is complete
      Specified by:
      close in interface AutoCloseable

    • isFinished

      public boolean isFinished()

    • isOldestLiveGroup

      public boolean isOldestLiveGroup()

    • await

      public void await()

    • prev

      public OpOrder.Group prev()

    • isBlocking

      public boolean isBlocking()
      Returns:
      true if a barrier we are behind is, or may be, blocking general progress, so we should try more aggressively to progress

    • notifyIfBlocking

      public void notifyIfBlocking(WaitQueue.Signal signal)

    • compareTo

      public int compareTo(OpOrder.Group that)
      Specified by:
      compareTo in interface Comparable<OpOrder.Group>