小编Dan*_*her的帖子

我试图在 TPL 数据流中控制数据流。我有一个非常快的生产者和一个非常慢的消费者。（我的实际代码更复杂，但无论如何，这是一个非常好的模型，它重现了问题。）

当我运行它时，代码开始消耗内存，就像它已经过时一样——并且生产者上的输出队列尽可能快地填满。我真正希望看到的是生产者停止运行一段时间，直到消费者有机会要求它。从我对文档的阅读来看，这就是应该发生的事情：也就是说，我认为生产者会等到消费者有空间。

事实并非如此，很明显。如何修复它以便队列不会发疯？

using System;
using System.Linq;
using System.Threading.Tasks;
using System.Threading.Tasks.Dataflow;
using System.Threading;

namespace MemoryLeakTestCase
{
    class Program
    {

        static void Main(string[] args)
        {
            var CreateData = new TransformManyBlock<int, string>(ignore =>
            {
                return Enumerable.Range(0, 1000 * 1000 * 1000).Select((s,i) => "Hello, World " + i);
            });

            var ParseFile = new TransformManyBlock<string, string>(fileContent =>
            {
                Thread.Sleep(1000);
                return Enumerable.Range(0, 100).Select((sst, iii) => "Hello, " + iii);
            }, new ExecutionDataflowBlockOptions() { BoundedCapacity = 1000 }
            );

            var EndOfTheLine = new ActionBlock<object>(f …