如果我没有完成一个 ActionBlock 会不会有问题

Posted 2023-03-31

【中文标题】如果我没有完成一个 ActionBlock 会不会有问题

【英文标题】：Will it be a problem if I do not complete an ActionBlock

【发布时间】：2021-05-21 08:25:32

【问题描述】：

我正在尝试使用动作块来执行一些任务。我的问题是当CreateActionBlock() 方法完成时，ActionBlock 仍在处理数据。由于方法返回，我没有办法调用actionBlock.Complete()。如果我运行这个CreateActionBlock() 千次会导致任何问题吗？内存中会永远存在数千个 actionBlock，还是会在处理完 5 个输入后被 GC？

private static async Task Dequeue(string content)

    Console.WriteLine("The string is " + content);
    await Task.Delay(10000);


public static void CreateActionBlock()

    var actionBlock = new ActionBlock<string>(
        (e) => Dequeue(e),
        new ExecutionDataflowBlockOptions()
        
            BoundedCapacity = 5,
            MaxDegreeOfParallelism = 1
        );

    for (int i = 0; i < 5; i++)
    
        actionBlock.Post(i.ToString());
    

【问题讨论】：

有些相关：Does linking keep the linked block alive?

“会不会引起任何问题”的答案是可能是的。动作块可以正常工作，GC 也可以正常工作，但是您的程序将不知道何时可以安全退出。所以从一个非常广泛的角度来看，即发即弃意味着你可以接受失去工作。大多数程序都不适合。但是，如果您在程序退出时对丢失工作感到满意，那么这将起作用。

【参考方案1】：

只要输入队列被清空并且当前处于空闲状态，数据流块就有资格进行垃圾回收。以下是演示此行为的示例：

var weakReference = InnerMethod();
for (int i = 1; i <= 10; i++)

    Thread.Sleep(100);
    GC.Collect();
    Console.WriteLine($"IsAlive: weakReference.IsAlive");


WeakReference InnerMethod()

    var block = new ActionBlock<int>(n =>
    
        Thread.Sleep(200);
        Console.WriteLine($"Processed: n");
    );
    block.Post(1); block.Post(2); block.Post(3);
    return new WeakReference(block);

输出：

IsAlive: True
Processed: 1
IsAlive: True
IsAlive: True
Processed: 2
IsAlive: True
IsAlive: True
Processed: 3
IsAlive: False
IsAlive: False
IsAlive: False
IsAlive: False
IsAlive: False

(Try it on Fiddle)