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

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了c# – Parallel.For loop – 为每个线程分配唯一的数据实体，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1942字，纯文字阅读大概需要3分钟。

内容图文

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

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

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

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

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

Parallel.For(0, limit, new ParallelOptions { MaxDegreeOfParallelism = 10 }, 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, limit, new ParallelOptions { MaxDegreeOfParallelism = 10 }, 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, limit, new ParallelOptions { MaxDegreeOfParallelism = 10 }, i =>
    {
        DataEntity x = entities.Take();
        DoWork(i, x);
        entities.Add(x);
    });

内容总结

以上是互联网集市为您收集整理的c# – Parallel.For loop – 为每个线程分配唯一的数据实体全部内容，希望文章能够帮你解决c# – Parallel.For loop – 为每个线程分配唯一的数据实体所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端