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:
- java.lang.Iterable<E>,- java.util.Collection<E>,- java.util.concurrent.BlockingQueue<E>,- java.util.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 acontainer blocking queue.- Author:
- Eike Stepper
 
- 
- 
Nested Class Summary- 
Nested classes/interfaces inherited from class org.eclipse.net4j.util.container.delegate.AbstractDelegatorAbstractDelegator.DelegatingIterator
 - 
Nested classes/interfaces inherited from interface org.eclipse.net4j.util.container.IContainerIContainer.Modifiable<E>, IContainer.Persistable<E>, IContainer.Persistence<E>
 - 
Nested classes/interfaces inherited from interface org.eclipse.net4j.util.event.INotifierINotifier.INotifier2
 
- 
 - 
Constructor SummaryConstructors Constructor Description ContainerBlockingQueue(java.util.concurrent.BlockingQueue<E> delegate)
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description intdrainTo(java.util.Collection<? super E> c)intdrainTo(java.util.Collection<? super E> c, int maxElements)java.util.concurrent.BlockingQueue<E>getDelegate()booleanoffer(E o, long timeout, java.util.concurrent.TimeUnit unit)Epoll(long timeout, java.util.concurrent.TimeUnit unit)voidput(E o)intremainingCapacity()Etake()- 
Methods inherited from class org.eclipse.net4j.util.container.delegate.ContainerQueueelement, offer, peek, poll, remove
 - 
Methods inherited from class org.eclipse.net4j.util.container.delegate.ContainerCollectionadd, addAll, clear, contains, containsAll, equals, getElements, hashCode, isEmpty, iterator, remove, removeAll, retainAll, size, toArray, toArray
 - 
Methods inherited from class org.eclipse.net4j.util.container.delegate.AbstractDelegatorcreateEvent, dispatchEvent, fireAddedEvent, fireRemovedEvent
 - 
Methods inherited from class org.eclipse.net4j.util.event.NotifieraddListener, addUniqueListener, fireEvent, fireEvent, fireEvent, fireThrowable, firstListenerAdded, getListeners, getNotificationService, hasListener, hasListeners, lastListenerRemoved, listenerAdded, listenerRemoved, removeListener
 - 
Methods inherited from class java.lang.Objectclone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
 - 
Methods inherited from interface java.util.CollectionaddAll, clear, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray, toArray
 - 
Methods inherited from interface org.eclipse.net4j.util.container.IContainergetElements, isEmpty
 - 
Methods inherited from interface org.eclipse.net4j.util.event.INotifieraddListener, getListeners, hasListeners, removeListener
 
- 
 
- 
- 
- 
Constructor Detail- 
ContainerBlockingQueuepublic ContainerBlockingQueue(java.util.concurrent.BlockingQueue<E> delegate) 
 
- 
 - 
Method Detail- 
getDelegatepublic java.util.concurrent.BlockingQueue<E> getDelegate() - Specified by:
- getDelegatein interface- IContainerBlockingQueue<E>
- Specified by:
- getDelegatein interface- IContainerCollection<E>
- Specified by:
- getDelegatein interface- IContainerQueue<E>
- Overrides:
- getDelegatein class- ContainerQueue<E>
 
 - 
drainTopublic int drainTo(java.util.Collection<? super E> c) - Specified by:
- drainToin interface- java.util.concurrent.BlockingQueue<E>
- Category
- WRITE
 
 - 
drainTopublic int drainTo(java.util.Collection<? super E> c, int maxElements) - Specified by:
- drainToin interface- java.util.concurrent.BlockingQueue<E>
- Category
- WRITE
 
 - 
offerpublic boolean offer(E o, long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException - Specified by:
- offerin interface- java.util.concurrent.BlockingQueue<E>
- Throws:
- java.lang.InterruptedException
- Category
- WRITE
 
 - 
pollpublic E poll(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException - Specified by:
- pollin interface- java.util.concurrent.BlockingQueue<E>
- Throws:
- java.lang.InterruptedException
- Category
- WRITE
 
 - 
putpublic void put(E o) throws java.lang.InterruptedException - Specified by:
- putin interface- java.util.concurrent.BlockingQueue<E>
- Throws:
- java.lang.InterruptedException
- Category
- WRITE
 
 - 
remainingCapacitypublic int remainingCapacity() - Specified by:
- remainingCapacityin interface- java.util.concurrent.BlockingQueue<E>
- Category
- READ
 
 
- 
 
-