com.sleepycat.je.rep.utilint

Class RepUtils.ExceptionAwareBlockingQueue<T>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.LinkedBlockingQueue<T>

com.sleepycat.je.rep.utilint.RepUtils.ExceptionAwareBlockingQueue<T>

All Implemented Interfaces:

java.io.Serializable, java.lang.Iterable<T>, java.util.Collection<T>, java.util.concurrent.BlockingQueue<T>, java.util.Queue<T>

Enclosing class:

RepUtils

public static class RepUtils.ExceptionAwareBlockingQueue<T>
extends java.util.concurrent.LinkedBlockingQueue<T>

Like LinkedBlockingQueue, but provides a pollOrException() method that should be used instead of poll(), so that callers don't have to treat exception cases specially.

See Also:

RepUtils.ExceptionAwareCountDownLatch, Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
(package private) T	dummyValue
(package private) EnvironmentImpl	envImpl

Constructor Summary

Constructors

Constructor and Description
RepUtils.ExceptionAwareBlockingQueue(EnvironmentImpl envImpl, T dummyValue)

Method Summary

Methods

Modifier and Type	Method and Description
T	poll(long timeout, java.util.concurrent.TimeUnit unit) Deprecated.
T	pollOrException(long timeout, java.util.concurrent.TimeUnit unit)
void	releasePoll(java.lang.Exception e)

Methods inherited from class java.util.concurrent.LinkedBlockingQueue

clear, contains, drainTo, drainTo, iterator, offer, offer, peek, poll, put, remainingCapacity, remove, size, take, toArray, toArray, toString

Methods inherited from class java.util.AbstractQueue

add, addAll, element, remove

Methods inherited from class java.util.AbstractCollection

containsAll, isEmpty, removeAll, retainAll

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.BlockingQueue

add

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

addAll, containsAll, equals, hashCode, isEmpty, removeAll, retainAll

Field Detail

envImpl

final EnvironmentImpl envImpl

dummyValue

final T dummyValue

Constructor Detail

RepUtils.ExceptionAwareBlockingQueue

public RepUtils.ExceptionAwareBlockingQueue(EnvironmentImpl envImpl,
                                    T dummyValue)

Method Detail

releasePoll

public void releasePoll(java.lang.Exception e)

pollOrException

public T pollOrException(long timeout,
                java.util.concurrent.TimeUnit unit)
                  throws java.lang.InterruptedException,
                         DatabaseException

Throws:

java.lang.InterruptedException

DatabaseException

poll

@Deprecated
public T poll(long timeout,
                java.util.concurrent.TimeUnit unit)

Deprecated.

(Use pollOrException(long, java.util.concurrent.TimeUnit) instead.

Specified by:

poll in interface java.util.concurrent.BlockingQueue<T>

Overrides:

poll in class java.util.concurrent.LinkedBlockingQueue<T>