Race condition in StreamThread state change

In the call to `StreamThread.addRecordsToTasks` we don't have synchronization when we attempt to extract active tasks. If after one long poll in runOnce the application state changes to PENDING_SHUTDOWN, there is a potential close on TaskManager which erases the active tasks map, thus triggering NPE and bringing the thread state to a false shutdown.