Streams 131

Why is cleanUp() moved to after isRunning.set(false)?  I believe you are creating a race condition here.  The ProcesssorTask should still be running while its cleaning up.  That way the task cannot be put up for garbage collection while its cleaning up.  In cleaning up, it could be emptying internal queues or closing connections.  All things we want to guarantee happen.  Has the implementation changed so that this i not the case?