ZeroMQ implements this pattern really well. It's just single threaded code... all the threading happens in the background... There's also apache storm which a

ZeroMQ implements this pattern really well. It's just single threaded code... all the threading happens in the background... There's also apache storm which abstracts you from all the gory details of spinning up workers, pools, tracking message failure, etc.