任务数据流，可以从完成状态更改数据块吗？

Question

我想知道是否可以改变数据块的完成状态？

例如，我用block.Complete() 标记了一个完整的var block = new BufferBlock<int>(); 数据块。该块链接到其他数据块。我想知道是否可以通过将 block 的完成状态更改回其原始 !complete 状态来再次运行。

如果这是不可能的，我如何执行多次运行，包括完成，而不必 a) 取消链接所有块，b) 重新实例化所有块，以及 c) 再次重新链接所有块？

有什么想法可以简化运行数据流周期的任务，包括完成链下的每个块，而无需重新创建整个框架？

谢谢

Answer 1

不，您不能“取消完成”已完成的数据流块。我认为您应该做的是为每条消息添加一个标志，说明它是否是运行中的最后一条消息。为了使其更易于使用，您可以创建一组辅助方法，例如：

public static TransformBlock<Tuple<TInput, bool>, Tuple<TOutput, bool>>
    CreateEnhancedTransformBlock<TInput, TOutput>(Func<TInput, TOutput> transform)
{
    return new TransformBlock<Tuple<TInput, bool>, Tuple<TOutput, bool>>(
        tuple => Tuple.Create(transform(tuple.Item1), tuple.Item2));
}

这样，您输入一个仅处理TInput 和TOuput 的transform 委托，并且该标志与每条消息一起传输。