tpl 数据流：固定缓冲区大小而不会丢弃项目

Question

在玩过数据流之后，我遇到了一个新问题。我想限制所有块的输入队列。我的生产块 (ActionBlock) 正在快速创建 5000 个元素并将它们发布到广播块。因此，如果我将广播块的 BoundedCapacity 设置为 100，他会丢弃大量数据。但我更希望生产块等待缓冲区块的输入队列中的新插槽。

有什么办法可以解决这个问题？

Answer 1

这正是BufferBlock 的用途。如果您设置它的BoundedCapacity 并且它已满，它将推迟接收任何消息，直到有人消费它们。这意味着例如Post() 将阻塞，SendAsync() 将返回一个未完成的Task。

编辑：没有内置块可以发送到多个目标并且从不丢弃数据。但是您可以通过ActionBlock 和发送循环轻松地自己构建一个：

static ITargetBlock<T> CreateMultipleTargetsBlock<T>(
    IEnumerable<ITargetBlock<T>> targets, int boundedCapacity)
{
    var targetsList = targets.ToList();

    var block = new ActionBlock<T>(
        async item =>
        {
            foreach (var target in targetsList)
            {
                await target.SendAsync(item);
            }
        },
        new ExecutionDataflowBlockOptions { BoundedCapacity = boundedCapacity });

    // TODO: propagate completion from block to targets

    return block;
}

此代码假定您不需要为每个目标克隆数据并且目标列表永远不会更改。修改代码应该相当简单。