PriorityJobQueueTest: proper way of asserting the number of data processed.
Fixing PriorityJobQueueTest: needed to wait on the futures.