fix up some concurrent worker queue bugs