producer/consumer work queues

I\'m wrestling with the best way to implement my processing pipeline. My producers feed work to a BlockingQueue.On the consumer side, I poll the queue, wrap what I get in a Runnable task, and submit