So most of the times I'm actually using a blocking queue with finite capacity so that I see when I'm being too fast on the front.