c# - Looped Parallel.For 没有给出预期的结果

问题描述

我正在另一个 Parallel.For 循环中测试 Parallel.For 循环。结果预计是从 1 到 500 递增 1 个单位的数字。但输出始终是这样的：

如您所见，缺少一些东西...我为此编写了小程序。所以这里是：

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading;
using System.Threading.Tasks;
using System.Web;

namespace testProjectCSharp
{
    class Program
    {
        static void Main(string[] args)
        {
            string[] numbersFromParallel = new string[500];

            ParallelOptions option1 = new ParallelOptions();
            option1.MaxDegreeOfParallelism = 10;
            ParallelOptions option2 = new ParallelOptions();
            option2.MaxDegreeOfParallelism = 10;

            Parallel.For(1, 51, option1, i =>
            {
                Parallel.For(1, 11, option2, g =>
                {
                    numbersFromParallel[(i * g) - 1] = ((i * g) - 1).ToString();
                });
            });

            File.WriteAllLines(@"C:\tempArrayTest.txt", numbersFromParallel);
            Console.WriteLine("Done.");

            Console.ReadLine();
        }
    }
}

标签： c#

解决方案

numbersFromParallel数组索引的计算是错误的。假设您的范围是从0到4没有-1偏移量（所以只有i*g）。然后您将生成以下值：

	g=1	g=2	g=3	g=4
我=0	0	0	0	0
我=1	1	2	3	4
我=2	2	4	6	8
我=3	3	6	9	12
我=4	4	8	12	16

有很多跳过的数字（如5或10），有些值是重复的（如0、3或12）。

你想要的是一个表达式，比如5*i + g获取如下值：

	g=0	g=1	g=2	g=3	g=4
我=0 (0)	0	1	2	3	4
我=1 (5)	5	6	7	8	9
我=2 (10)	10	11	12	13	14
我=3 (15)	15	16	17	18	19
我=4 (20)	20	21	22	23	24

所以你必须像这样调整Parallel.For循环：

int count_x = 50;
int count_y = 10;    
string[] numbersFromParallel = new string[count_x*count_y];

// ...

Parallel.For(0, count_x, option1, i =>
{
    Parallel.For(0, count_y, option2, g =>
    {
        int index = i*count_y + g;      
        numbersFromParallel[index] = index.ToString();
    });
});

c# - Looped Parallel.For 没有给出预期的结果

问题描述

解决方案

推荐阅读