concurrent-unique-queue

concurrent-unique-queue copied to clipboard

BlockingQueue documentation for `offer()` method says it should return `true` upon success and `false` if no space is currently available. I think this block in ConcurrentSetBlockingQueue should return `true` instead...

jruaux

ConcurrentModifications exceptions

1

Hi, I'm getting ConcurrentModificationExceptions while attempting to use two threads to put/take from the queue. I do have a question around locking. There are takeLock's and putLock's... But I don't...

martinrosstmc

Please, extend functionality to be possible to add predifined number of each element in queue (i.e. not more than "given number"). HashMap maybe? Thank you.

ghYura

`ConcurrentSetQueue#poll()` contains a call to `set.spliterator()` whose results is not used, so I suspect it can be removed.

ciufudean