Package org.eclipse.rdf4j.common.concurrent.locks

Class LockingIteration<E,​X extends Exception>

java.lang.Object
org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration<E,​X>
org.eclipse.rdf4j.common.iteration.IterationWrapper<E,​X>
org.eclipse.rdf4j.common.concurrent.locks.LockingIteration<E,​X>
All Implemented Interfaces:
AutoCloseable, CloseableIteration<E,​X>, Iteration<E,​X>
public class LockingIteration<E,​X extends Exception> extends IterationWrapper<E,​X>
An Iteration that holds on to a lock until the Iteration is closed. Upon closing, the underlying Iteration is closed before the lock is released. This iterator closes itself as soon as all elements have been read.

  • Constructor Details

    • LockingIteration

      public LockingIteration​(Lock lock, Iteration<? extends E,​X> iter)
      Creates a new LockingIteration.
      Parameters:
      lock - The lock to release when the itererator is closed, must not be null.
      iter - The underlying Iteration, must not be null.

  • Method Details