Update delayed worker to be multithreaded.
Add support for multiple queues.