Class ContainerBlockingQueue<E>
java.lang.Object
org.eclipse.net4j.util.event.Notifier
org.eclipse.net4j.util.container.delegate.AbstractDelegator<E>
org.eclipse.net4j.util.container.delegate.ContainerCollection<E>
org.eclipse.net4j.util.container.delegate.ContainerQueue<E>
org.eclipse.net4j.util.container.delegate.ContainerBlockingQueue<E>
- All Implemented Interfaces:
Iterable<E>,Collection<E>,BlockingQueue<E>,Queue<E>,IContainerBlockingQueue<E>,IContainerCollection<E>,IContainerQueue<E>,IContainer<E>,INotifier,INotifier.INotifier2
public class ContainerBlockingQueue<E>
extends ContainerQueue<E>
implements IContainerBlockingQueue<E>
A default implementation of a
container blocking queue.- Author:
- Eike Stepper
-
Nested Class Summary
Nested classes/interfaces inherited from class org.eclipse.net4j.util.container.delegate.AbstractDelegator
AbstractDelegator.DelegatingIteratorNested classes/interfaces inherited from interface org.eclipse.net4j.util.container.IContainer
IContainer.Modifiable<E>, IContainer.Persistable<E>, IContainer.Persistence<E>Nested classes/interfaces inherited from interface org.eclipse.net4j.util.event.INotifier
INotifier.INotifier2 -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionintdrainTo(Collection<? super E> c) intdrainTo(Collection<? super E> c, int maxElements) booleanvoidinttake()Methods inherited from class org.eclipse.net4j.util.container.delegate.ContainerQueue
element, offer, peek, poll, removeMethods inherited from class org.eclipse.net4j.util.container.delegate.ContainerCollection
add, addAll, clear, contains, containsAll, equals, getElements, hashCode, isEmpty, iterator, remove, removeAll, retainAll, size, toArray, toArrayMethods inherited from class org.eclipse.net4j.util.container.delegate.AbstractDelegator
createEvent, dispatchEvent, fireAddedEvent, fireRemovedEventMethods inherited from class org.eclipse.net4j.util.event.Notifier
addListener, addUniqueListener, fireEvent, fireEvent, fireEvent, fireThrowable, firstListenerAdded, getListeners, getNotificationService, hasListener, hasListeners, lastListenerRemoved, listenerAdded, listenerRemoved, removeListenerMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface java.util.concurrent.BlockingQueue
add, contains, offer, removeMethods inherited from interface java.util.Collection
addAll, clear, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray, toArrayMethods inherited from interface org.eclipse.net4j.util.container.IContainer
getElements, isEmptyMethods inherited from interface org.eclipse.net4j.util.event.INotifier
addListener, getListeners, hasListeners, removeListener
-
Constructor Details
-
ContainerBlockingQueue
-
-
Method Details
-
getDelegate
- Specified by:
getDelegatein interfaceIContainerBlockingQueue<E>- Specified by:
getDelegatein interfaceIContainerCollection<E>- Specified by:
getDelegatein interfaceIContainerQueue<E>- Overrides:
getDelegatein classContainerQueue<E>
-
drainTo
- Specified by:
drainToin interfaceBlockingQueue<E>- Category
- WRITE
-
drainTo
- Specified by:
drainToin interfaceBlockingQueue<E>- Category
- WRITE
-
offer
- Specified by:
offerin interfaceBlockingQueue<E>- Throws:
InterruptedException- Category
- WRITE
-
poll
- Specified by:
pollin interfaceBlockingQueue<E>- Throws:
InterruptedException- Category
- WRITE
-
put
- Specified by:
putin interfaceBlockingQueue<E>- Throws:
InterruptedException- Category
- WRITE
-
remainingCapacity
public int remainingCapacity()- Specified by:
remainingCapacityin interfaceBlockingQueue<E>- Category
- READ
-
take
- Specified by:
takein interfaceBlockingQueue<E>- Throws:
InterruptedException- Category
- WRITE
-