如何使用PLINQ并行化for-cycle

本文关键字：for-cycle 并行化 PLINQ 何使用 | 更新日期: 2023-09-27 18:19:18

我有一个使用PLINQ并行化迭代的任务。我有一个基于For循环的函数:

public void PointGenerator(int n, Random rnd)
{
    for (int i = 1; i <= n; i++)
    {
        x = rnd.NextDouble(); 
        y = rnd.NextDouble(); // 
        if (((x - 0.5) * (x - 0.5) + (y - 0.5) * (y - 0.5)) < 0.25)
        {
            N_0++;
        }
    }
}

如何使用PLINQ?

如何使用PLINQ并行化for-cycle

您可以这样尝试:

public bool Check(double x, double y)
{
    return ((x - 0.5) * (x - 0.5) + (y - 0.5) * (y - 0.5)) < 0.25;    
}
// ...
N_0 = Enumerable
    .Range(0, n)
    .Select(i => new { X = rnd.NextDouble(), Y = rnd.NextDouble() })
    .AsParallel()
    .Count(p => Check(p.X, p.Y));

正如Roman Dvoskin在另一个答案下的评论中指出的那样，Random对象不是线程安全的:

然而，随机对象不是线程安全的。如果你的应用程序从多个线程调用随机方法，你必须使用一个同步对象来确保一次只有一个线程可以访问随机数生成器。如果不能确保以线程安全的方式访问Random对象，则调用返回随机数的方法将返回0。

这个问题可以通过先生成所有的XY对来解决。

在range上使用Parallel.ForEach方法:

var randLock = new object();
Parallel.ForEach(
    Enumerable.Range(1, n)
,   () => { // if you needed the index, you could use i instead of ()
        lock (randLock) {
            x = rnd.NextDouble(); 
            y = rnd.NextDouble();
        }
        if (((x - 0.5) * (x - 0.5) + (y - 0.5) * (y - 0.5)) < 0.25) {
            Interlocked.Increment(ref N_0);
        }
    });

注意使用Interlocked.Increment而不是N_0++来避免并发问题。randLock的使用也有同样的目的:根据文档，System.Random不是线程安全的。

相关文章：