ATM we're protecting the tasks queue that communicates tasks' publisher and consuming workers with a per worker mutex because queues themselves are not thread safe. We can use smarter queues with those guarantees and simplify our code