plinq

    1热度

    1回答

    我有以下代码 var myResponse = new Response(); Parallel .ForEach(itemsListDto , new ParallelOptions { MaxDegreeOfParallelism = 10 } , itemDto => { var tResponse = _itemService

    3热度

    1回答

    我想使用PLINQ在产品和类别之间执行内部连接。但我不确定是否应该为这两个集合调用AsParallel方法。 // PLINQ - Option 1 jointTables = from c in Homework02.categories.AsParallel() join p in Homework02.productList on c.Name equals p.Cat

    2热度

    1回答

    我试图使用PLINQ加快一个简单的模拟,但我设法慢下来,而不是(未注释进行AsParallel运行速度较慢): class Program { private static readonly Random Random = new Random(); private static IEnumerable<Tuple<double, double>> GetNextPair(

    3热度

    2回答

    我有两个包含相同类型对象的集合,两个集合都有大约40K个对象。 每个集合包含对象的代码基本上就像一本字典,除了我已经覆盖了equals和散列函数: public class MyClass: IEquatable<MyClass> { public int ID { get; set; } public string Name { get; set; } publ

    4热度

    1回答

    我正在使用PLINQ对数据进行并行操作。每个线程都会消耗大量的内存,这些内存是基于算法设置而变化的,所以根据算法选项预先计算需要多少内存并不容易。当内存要求较低时,最优的线程数为8,系统总数为8;当内存要求很高时,2个线程相对于1有显着的改进,但是一旦使用了3个线程,系统就开始触发分页文件,并且CPU利用率下降到0,并且性能下降了数百倍。 我希望能够做的是让PLINQ增量线程数量,同时监视内存负载

    4热度

    2回答

    我想用PLINQ方法AsParallel()重写这个Parallel.For循环。据我所见,AsParallel()需要传递一个完整的序列,例如创建数组A,然后调用A.AsParallel()。ForAll或A.AsParallel()。Select。有没有办法让AsParallel()在范围内工作 - 在这种情况下,从低到高? for k = 2 to m+n do let low =

    0热度

    1回答

    MSDN文章“Order Preservation in PLINQ”状态: 以下示例通过使用 AsOrdered操作者在源序列覆盖缺省行为。这确保了 采取方法返回源 序列中的第10个城市符合条件 var orderedCities = (from city in cities.AsParallel().AsOrdered() where city.Population > 10

    2热度

    1回答

    我有200,000个并行运行的任务可以提高速度。我正在使用ParallelEnumerable.Range(0, 200000).Sum(a => /*do_something*/)。 当任务计数器从0变到200,000时,所需的迭代次数减少。具有a=0的任务需要大量的迭代,而具有a>100,000的任务完成一次或不进行迭代。 由于这个原因,我的四核机器在任务进行时未达到最大cpu利用率峰值。看起

    3热度

    1回答

    我对PLINQ有一些奇怪的结果,我似乎无法解释。我一直在尝试对Alpha Beta树进行并行化搜索以加速搜索过程,但是它正在有效地减缓搜索速度。我期望提高并行度,我会每秒线性地增加节点数......并且在修剪被推出之前处理额外的节点。当节点数量相匹配的期望,我的时间不: 非PLINQ,参观 节点:61418, 运行时间:0:00.67 并行度:1,参观 节点:61418, 运行时:0:01.48

    5热度

    2回答

    linq的好处之一是可以根据请求懒散处理无限的数据源。我试着对我的查询进行并行处理,发现懒加载不起作用。例如... class Program { static void Main(string[] args) { var source = Generator(); var next = source.AsParallel().Select(i =>