c# – Parallel.For loop – 为每个线程分配唯一的数据实体

发布时间：2020-12-15 23:44:33 所属栏目：百科来源：网络整理

导读：我有100条并行化记录,从1到100,现在我可以方便地使用Parallel.For在Parallel中执行它们,如下所示,它将基于计算资源工作 Parallel.For(0,limit,i = { DoWork(i); }); 但是有一些限制,每个线程需要使用相同的数据实体,并且数据实体数量有限,例如10,它们是通过

我有100条并行化记录,从1到100,现在我可以方便地使用Parallel.For在Parallel中执行它们,如下所示,它将基于计算资源工作

Parallel.For(0,limit,i =>
    {
        DoWork(i);
    });

但是有一些限制,每个线程需要使用相同的数据实体,并且数据实体数量有限,例如10,它们是通过相互克隆并将它们保存在像Dictionary或List这样的结构中而先进创建的.现在我可以使用以下代码限制并行化的数量：

Parallel.For(0,new ParallelOptions { MaxDegreeOfParallelism = 10 },i =>
    {
        DoWork(i);
    });

但问题是如何为每个传入线程分配一个唯一的数据实体,这样任何其他当前线程都不会使用Data实体,因为线程和数据实体的数量是相同的,所以饥饿不是问题.我可以想到,我为每个数据实体创建一个布尔值,指定它是否正在使用,因此我们遍历字典或列表以查找下一个可用数据实体并锁定整个分配过程,以便一个线程在给定时间被分配了一个数据实体,但在我看来这个问题将有更优雅的解决方案,我的版本只是一个解决方法,而不是真正的修复.我的逻辑是：

Parallel.For(0,i =>
        {
            lock(All_Threads_Common_Object)
            {
              Check for available data entity using boolean
              Assign the Data entity
            }
            DoWork(i);

            Reset the Boolean value for another thread to use it
        });

如果问题需要进一步澄清,请告诉我

解决方法

您可以使用 concurrent collection存储10个对象.
每个工作人员将拉出一个数据实体,使用它并将其还原.并发收集的使用很重要,因为在您的方案中,正常的收集不是线程安全的.

像这样：

var queue = new ConcurrentQueue<DataEntity>();
// fill the queue with 10 items

Parallel.For(0,i =>
    {
        DataEntity x;
        if(!queue.TryDequeue(out x))
            throw new InvalidOperationException();
        DoWork(i,x);
        queue.Enqueue(x);
    });

或者,如果需要提供阻止,请将内容包装在BlockingCollection中.

编辑：不要将它包裹在循环中以保持等待.相反,使用像这样的BlockingCollection：

var entities = new BlockingCollection(new ConcurrentQueue<DataEntity>());

// fill the collection with 10 items

Parallel.For(0,i =>
    {
        DataEntity x = entities.Take();
        DoWork(i,x);
        entities.Add(x);
    });

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!