Class LockingIteration<E>

java.lang.Object

org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration<E>

org.eclipse.rdf4j.common.iteration.IterationWrapper<E>

org.eclipse.rdf4j.common.concurrent.locks.LockingIteration<E>

All Implemented Interfaces:

AutoCloseable, Iterator<E>, CloseableIteration<E>

public class LockingIteration<E>
extends IterationWrapper<E>

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.

Field Summary

Fields inherited from class IterationWrapper

wrappedIter

Fields inherited from interface CloseableIteration

EMPTY_STATEMENT_ITERATION

Method Summary

Modifier and Type	Method	Description
static <T, R extends Exception> CloseableIteration<T>	getInstance(Lock lock, CloseableIteration<T> iter)
protected void	handleClose()	Closes this Iteration and also closes the wrapped Iteration if it is a CloseableIteration.

Methods inherited from class IterationWrapper

hasNext, next, remove

Methods inherited from class AbstractCloseableIteration

close, isClosed

Methods inherited from class Object

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

Methods inherited from interface CloseableIteration

stream

Methods inherited from interface Iterator

forEachRemaining

Method Details

getInstance

public static <T, R extends Exception>
CloseableIteration<T> getInstance(Lock lock,
 CloseableIteration<T> iter)

handleClose

protected void handleClose()

Description copied from class: IterationWrapper

Closes this Iteration and also closes the wrapped Iteration if it is a CloseableIteration.

Overrides:

handleClose in class IterationWrapper<E>