Fix memory consumption for streaming tasks by bounding the max queue size
Merge pull request #28 from gatoatigrado/ntung-deadlock-fix-productionizing

Fix memory consumption for streaming tasks by bounding the max queue size