Initial commit of the DuplicateMergingPriorityQueue based on
ConcurrentSkipListSet - this should help us with race conditions arising
in priority queue.