I would like to use the constructor on the ExecutorCompletionService which takes a pre-defined BlockingQueue.