Finer-grained locking in StreamingInputVertex

[frankmcsherry]

StreamingInputVertex.PerformAction holds a lock on the object while it processes all of its input records (calls to output.Send()). This blocks any threads trying to enqueue work items. It seems that the lock should be able to held for less time, only related to variables/state that might be modified by other threads.