是否存在不接受输入但返回输出的TPL数据流块?

本文关键字：TPL 数据流 输出 返回 存在 不接受 输入 是否 | 更新日期: 2023-09-27 17:54:41

问题的标题说明了一切。

我正在寻找一个不需要输入的TPL数据流块。

现在我正在使用转换块，但它的输入是未使用的

是否存在不接受输入但返回输出的TPL数据流块?

我会从BufferBlock<T>建立一个这样的块:该方法接受一个代表块的ITargetBlock<T>侧并返回它的ISourceBlock<T>侧的委托。这样，委托可以向块发送输入，但从外部看，它看起来像一个只产生输出的块。

代码:

public static ISourceBlock<T> CreateProducerBlock<T>(
    Func<ITargetBlock<T>, Task> producer,
    int boundedCapacity = DataflowBlockOptions.Unbounded)
{
    var block = new BufferBlock<T>(
        new ExecutionDataflowBlockOptions { BoundedCapacity = boundedCapacity });
    Task.Run(async () =>
    {
        try
        {
            await producer(block);
            block.Complete();
        }
        catch (Exception ex)
        {
            ((IDataflowBlock)block).Fault(ex);
        }
    });
    return block;
}

使用例子:

var producer = CreateProducerBlock<int>(async target =>
{
    await target.SendAsync(10);
    await target.SendAsync(20);
});
ITargetBlock<int> consumer = …;
producer.LinkTo(consumer);

有时最简单的方法是使用一次性的bool作为TransformManyBlock的输入，并使用.Post(true)来启动您的管道。

相关文章：