fix calling cleanup function in Worker.run() to avoid race condition#1455