Contents
Is drainTo blocked?
drainTo definitely blocks any put, get, take, etc… Check the source code.
What is array blocking queue?
ArrayBlockingQueue class is a bounded blocking queue backed by an array. By bounded, it means that the size of the Queue is fixed. Once created, the capacity cannot be changed. Attempts to put an element into a full queue will result in the operation blocking. This class is a member of the Java Collections Framework.
Is ArrayBlockingQueue thread-safe?
BlockingQueue implementations are thread-safe. All queuing methods achieve their effects atomically using internal locks or other forms of concurrency control.
How to use BlockingQueue-blocked drainto method in Java?
Drains the queue as BlockingQueue.drainTo (Collection, int), but if the requested numElements elements are not available, it will wait for them up to the specified timeout. I found this pattern useful. With the API available, I don’t think you are going to get much more elegant.
How does the arrayblockingqueue method work in Java?
This method acts as bridge between array-based and collection-based APIs. Returns an array containing all of the elements in this queue, in proper sequence; the runtime type of the returned array is that of the specified array. If the queue fits in the specified array, it is returned therein.
Where are new elements inserted in arrayblockingqueue?
New elements are inserted at the tail of the queue, and the queue retrieval operations obtain elements at the head of the queue. This is a classic “bounded buffer”, in which a fixed-sized array holds elements inserted by producers and extracted by consumers.
Is there a BlockingQueue method that is not blocked?
BlockingQueue has the method called drainTo () but it is not blocked. I need a queue that I want to block but also able to retrieve queued objects in a single method. I guess the above code will work but I’m looking for an elegant solution.