并发队列出队

Question

我正在使用并发队列并通过创建动作委托通过多个线程从队列中取出数据

Action action = () =>
        {
            SubscriptionResponseModel subsModel;
            while (concurrentQueue.TryTake(out subsModel))
            {
                MakeTransactionAndAddIntoQueue(subsModel);
            }
        };

并调用此动作委托并行多线程

Parallel.Invoke(action, action, action, action, action, action, action, action, action, action, action, action, action, action, action);

我想知道一件事，当我在多个操作中使用SubscriptionResponseModel subsModel; 时，它是线程安全的吗？

Answer 1

action 的每次调用都会有自己的subsModel - 因此使用它从队列中获取值是线程安全的。

当你从外部上下文中捕获变量时，它不是线程安全的：

    // ********** Code showing non-thread safe case **************
    SubscriptionResponseModel subsModel;
    Action action = () =>
    {
        // all invocations of `action` will share subsModel as it is captured.
        while (concurrentQueue.TryDequeue(out subsModel))
        {
            MakeTransactionAndAddIntoQueue(subsModel);
        }
    };

注意事项：

• 是否使用SubscriptionResponseModel 的属性/方法是线程安全的取决于该类型。
• 很有可能并行运行多个TryDequeue 根本不会提高性能。 Parallel.Invoke 的多个繁忙循环只会阻塞多个线程不断查询空队列。