Re: Stumped. How to add a limit to a LinkedBlockingQueue
Bogus Exception wrote:
Patricia,
Thanks so much for writing!
Patricia Shanahan wrote:
What does the ObjectListQueue constructor look like? Not the calls to
it, its implementation.
(from above) I instantiate these objects in the top level class with:
[...]
ObjectListQueue qCPin = new ObjectListQueue(), qCin = new
ObjectListQueue();
// outbound queues (arrays, with each destination as an element)
ObjectListQueue[] aGout = {qCPin}, aCPout = {qCin};
[...]
Where input queues are single (multiple producers can talk to a single
consumer), and output queues are arrays (a single producer can send to
pultiple consumers).
Is that clear? Sorry if it looks confusing! :)
TIA!
Bogus Exception
I'm still not getting the critical data, although the fact that it is
invisible to you probably gives the answer.
In the implementation of ObjectListQueue there is a constructor, either
explicit or default. If you did not provide one yourself, or if you
provide one but it does not contain an explicit "super" call, it will
call the parameterless constructor for the immediate superclass.
In this case, the parameterless LinkedBlockingQueue sets capacity
Integer.MAX_VALUE, which is a good idea if, and only if, something else
is limiting the number of items on the queue.
LinkedBlockingQueue also has a constructor that takes a capacity as
parameter. You need to call that constructor from the ObjectListQueue
constructor, which means you must have an explicit ObjectListQueue
constructor, not just a compiler-supplied default.
Patricia