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

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