public static class RepUtils.ExceptionAwareBlockingQueue<T>
extends java.util.concurrent.LinkedBlockingQueue<T>
LinkedBlockingQueue
, but provides a pollOrException()
method that should be used instead of poll()
,
so that callers don't have to treat exception cases specially.Modifier and Type | Field and Description |
---|---|
(package private) T |
dummyValue |
(package private) EnvironmentImpl |
envImpl |
Constructor and Description |
---|
RepUtils.ExceptionAwareBlockingQueue(EnvironmentImpl envImpl,
T dummyValue) |
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) |
clear, contains, drainTo, drainTo, iterator, offer, offer, peek, poll, put, remainingCapacity, remove, size, take, toArray, toArray, toString
containsAll, isEmpty, removeAll, retainAll
final EnvironmentImpl envImpl
final T dummyValue
public RepUtils.ExceptionAwareBlockingQueue(EnvironmentImpl envImpl, T dummyValue)
public void releasePoll(java.lang.Exception e)
public T pollOrException(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, DatabaseException
java.lang.InterruptedException
DatabaseException
@Deprecated public T poll(long timeout, java.util.concurrent.TimeUnit unit)
pollOrException(long, java.util.concurrent.TimeUnit)
instead.Copyright (c) 2004-2012 Oracle. All rights reserved.