When should I use SynchronousQueue over LinkedBlockingQueue
Solution 1
the SynchronousQueue is more of a handoff, whereas the LinkedBlockingQueue just allows a single element. The difference being that the put() call to a SynchronousQueue will not return until there is a corresponding take() call, but with a LinkedBlockingQueue of size 1, the put() call (to an empty queue) will return immediately.
I can't say that i have ever used the SynchronousQueue directly myself, but it is the default BlockingQueue used for the Executors.newCachedThreadPool()
methods. It's essentially the BlockingQueue implementation for when you don't really want a queue (you don't want to maintain any pending data).
Solution 2
As far as I understand code above do the same things.
No, the code is not the same at all.
Sync.Q. requires to have waiter(s) for offer to succeed. LBQ will keep the item and offer will finish immediately even if there is no waiter.
SyncQ is useful for tasks handoff. Imagine you have a list w/ pending task and 3 threads available waiting on the queue, try offer()
with 1/4 of the list if not accepted the thread can run the task on its own. [the last 1/4 should be handled by the current thread, if you wonder why 1/4 and not 1/3]
Think of trying to hand the task to a worker, if none is available you have an option to execute the task on your own (or throw an exception). On the contrary w/ LBQ, leaving the task in the queue doesn't guarantee any execution.
Note: the case w/ consumers and publishers is the same, i.e. the publisher may block and wait for consumers but after offer
or poll
returns, it ensures the task/element is to be handled.
Solution 3
One reason to use SynchronousQueue is to improve application performance. If you must have a hand-off between threads, you will need some synchronization object. If you can satisfy the conditions required for its use, SynchronousQueue is the fastest synchronization object I have found. Others agree. See: Implementation of BlockingQueue: What are the differences between SynchronousQueue and LinkedBlockingQueue
Solution 4
[Just trying to put it in (possibly) more clearer words.]
I believe the SynchronousQueue
API docs states things very clearly:
- A blocking queue in which each insert operation must wait for a corresponding remove operation by another thread, and vice versa.
- A synchronous queue does not have any internal capacity, not even a capacity of one. You cannot peek at a synchronous queue because an element is only present when you try to remove it; you cannot insert an element (using any method) unless another thread is trying to remove it; you cannot iterate as there is nothing to iterate.
- The head of the queue is the element that the first queued inserting thread is trying to add to the queue; if there is no such queued thread then no element is available for removal and
poll()
will returnnull
.
- A Queue that additionally supports operations that wait for the queue to become non-empty when retrieving an element, and wait for space to become available in the queue when storing an element.
So the difference is obvious and somewhat critically subtle, especially the 3rd point below:
- If the queue is empty when you are retrieving from
BlockingQueue
, the operation block till the new element is inserted. Also, if the queue is full when you are inserting in theBlockingQueue
, the operation will block till the element is removed from the queue and a space is made for the new queue. However note that inSynchronousQueue
, as operation is blocked for opposite operation (insert and remove are opposite of each other) to occur on another thread. So, unlikeBlockingQueue
, the blocking depends on the existence of the operation, instead of existence or non existence of an element. - As the blocking is dependent on existence of opposite operation, the element never really gets inserted in the queue. Thats why the second point: "A synchronous queue does not have any internal capacity, not even a capacity of one."
- As a consequence,
peek()
always returnsnull
(again, check the API doc) anditerator()
returns an empty iterator in whichhasNext()
always returnsfalse
. (API doc). However, note that thepoll()
method neatly retrieves and removes the head of this queue, if another thread is currently making an element available and if no such thread exists, it returnsnull
. (API doc)
Finally, a small note, both SynchronousQueue
and LinkedBlockingQueue
classes implement BlockingQueue
interface.
Solution 5
SynchronousQueue works in a similar fashion with following major differences: 1) The size of SynchronousQueue is 0 2) put() method will only insert an element if take() method will be able to fetch that element from the queue at the same moment i.e. an element cannot be inserted if the consumer take() call is going to take some time to consume it.
SynchronousQueue - Insert only when someone will receive it at that moment itself.
Anton
Updated on May 25, 2021Comments
-
Anton almost 3 years
new SynchronousQueue() new LinkedBlockingQueue(1)
What is the difference? When I should use
SynchronousQueue
againstLinkedBlockingQueue
with capacity 1?