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:
- Serializable, Iterable<T>, Collection<T>, BlockingQueue<T>, Queue<T>
- Enclosing class:
- RepUtils
public static class RepUtils.ExceptionAwareBlockingQueue<T>
- extends 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
Methods inherited from class java.util.concurrent.LinkedBlockingQueue |
clear, drainTo, drainTo, iterator, offer, offer, peek, poll, put, remainingCapacity, remove, size, take, toArray, toArray, toString |
envImpl
final EnvironmentImpl envImpl
dummyValue
final T dummyValue
RepUtils.ExceptionAwareBlockingQueue
public RepUtils.ExceptionAwareBlockingQueue(EnvironmentImpl envImpl,
T dummyValue)
releasePoll
public void releasePoll(Exception e)
pollOrException
public T pollOrException(long timeout,
TimeUnit unit)
throws InterruptedException,
DatabaseException
- Throws:
InterruptedException
DatabaseException
poll
@Deprecated
public T poll(long timeout,
TimeUnit unit)
- Deprecated.
- (Use
pollOrException(long, java.util.concurrent.TimeUnit)
instead.
- Specified by:
poll
in interface BlockingQueue<T>
- Overrides:
poll
in class LinkedBlockingQueue<T>
Copyright (c) 2004-2012 Oracle. All rights reserved.