Package org.eclipse.rdf4j.query.impl
Class QueueCursor<E>
- java.lang.Object
-
- org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration<E>
-
- org.eclipse.rdf4j.common.iteration.LookAheadIteration<E>
-
- org.eclipse.rdf4j.common.iteration.QueueIteration<E,QueryEvaluationException>
-
- org.eclipse.rdf4j.query.impl.QueueCursor<E>
-
- All Implemented Interfaces:
AutoCloseable
,Iterator<E>
,CloseableIteration<E>
- Direct Known Subclasses:
FedXQueueCursor
public class QueueCursor<E> extends QueueIteration<E,QueryEvaluationException>
Makes working with a queue easier by adding the methodsQueueIteration.done()
andQueueIteration.toss(Exception)
and automatically converting the exception into a QueryEvaluationException with an appropriate stack trace.- Author:
- James Leigh
-
-
Constructor Summary
Constructors Constructor Description QueueCursor(int capacity)
Creates an QueueCursor with the given (fixed) capacity and default access policy.QueueCursor(BlockingQueue<E> queue)
Deprecated.WeakReference is no longer supported as a way to automatically close this iteration.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected QueryEvaluationException
convert(Exception e)
Converts an exception from the underlying iteration to an exception of type X.-
Methods inherited from class org.eclipse.rdf4j.common.iteration.QueueIteration
checkException, done, getNextElement, handleClose, put, toss
-
Methods inherited from class org.eclipse.rdf4j.common.iteration.LookAheadIteration
hasNext, next, remove
-
Methods inherited from class org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration
close, isClosed
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.eclipse.rdf4j.common.iteration.CloseableIteration
stream
-
Methods inherited from interface java.util.Iterator
forEachRemaining
-
-
-
-
Constructor Detail
-
QueueCursor
public QueueCursor(int capacity)
Creates an QueueCursor with the given (fixed) capacity and default access policy.- Parameters:
capacity
- the capacity of this queue
-
QueueCursor
public QueueCursor(BlockingQueue<E> queue)
Deprecated.WeakReference is no longer supported as a way to automatically close this iteration. The recommended approach to automatically closing an iteration on garbage collection is to use aCleaner
.Creates an QueueCursor with the givenBlockingQueue
as its backing queue.
It may not be threadsafe to modify or access the givenBlockingQueue
from other locations. This method only enables the defaultArrayBlockingQueue
to be overridden.- Parameters:
queue
- A BlockingQueue that is not used in other locations, but will be used as the backing Queue implementation for this cursor.
-
-
Method Detail
-
convert
protected QueryEvaluationException convert(Exception e)
Description copied from class:QueueIteration
Converts an exception from the underlying iteration to an exception of type X.- Specified by:
convert
in classQueueIteration<E,QueryEvaluationException>
-
-