1

次のコードは、約 2.5 秒で実行されます。

static void Main(string[] args)
{
    var service = new Service();
    Parallel.For(0, 100, i => {
        dynamic user = new ExpandoObject();
        user.data = new ExpandoObject();
        user.data.id = i;
        user.data.name = "User Name";
        var parsed = service.Parse(user);
    });
}

public class Service
{
    public User Parse(dynamic dynamicUser)
    {
        if (dynamicUser.data != null)
        {
            return new User
            {
                Id = dynamicUser.data.id,
                Name = dynamicUser.data.name
            };
        }
        return null;
    }
}

public class User
{
    public int Id { get; set; }
    public string Name { get; set; }
}

ただし、Parallel.For() ループを単純な For ループに変更すると、約 200 ミリ秒で実行されます。

for (var i = 0; i < 100; i++)

私の質問は、並列実行するとなぜこれがずっと遅いのですか?

私の理論では、スレッドごとに 1 回行われる動的オブジェクトの解析にはオーバーヘッドがあるというものです。単純なループでは、DLR は最初にその処理を実行し、その後の各呼び出しでは必要ありません。

ただし、並行して、各呼び出しで DLR のオーバーヘッドが発生します。

これは正しい仮定ですか、それともベースから外れていますか?

4

2 に答える 2

3

診断結果に惑わされていると思います。特に、ループを100回実行するのに 2.5 秒かかる場合、それは非常に遅いことです。ひょっとして、これはデバッガーの下にあるのでしょうか?

これは、私のボックスでコンパイルし/o+てコンソールで実行したコードの結果です。各テストで 1,000,000 回のループ反復を実行していることに注意してください。

Void ExecuteParallel(): 00:00:00.7311773
Void ExecuteSerial(): 00:00:02.0514120
Void ExecuteParallel(): 00:00:00.6897816
Void ExecuteSerial(): 00:00:02.0389325
Void ExecuteParallel(): 00:00:00.6754025
Void ExecuteSerial(): 00:00:02.0653801
Void ExecuteParallel(): 00:00:00.7136330
Void ExecuteSerial(): 00:00:02.0477593
Void ExecuteParallel(): 00:00:00.6742260
Void ExecuteSerial(): 00:00:02.0476146

クアッドコアi7に期待されるほど並列で高速ではありませんが、それはServyが言及したコンテキストスイッチなどが原因であると思われます-また、DLRの実行キャッシュでの競合も考えられます. それでも、連続して実行するよりも高速です。

自分でコードを試して、ボックスで何が得られるかを確認してください。ただし、デバッガーではありません。

コード：

using System;
using System.Diagnostics;
using System.Dynamic;
using System.Threading.Tasks;

class Test
{
    const int Iterations = 1000000;

    static void Main(string[] args)
    {
        for (int i = 0; i < 5; i++)
        {
            RunTest(ExecuteParallel);
            RunTest(ExecuteSerial);
        }

    }

    static void RunTest(Action action)
    {
        var sw = Stopwatch.StartNew();
        action();
        sw.Stop();
        Console.WriteLine("{0}: {1}", action.Method, sw.Elapsed);
    }

    static void ExecuteParallel()
    {
        var service = new Service();
        Parallel.For(0, Iterations, i => {
            dynamic user = new ExpandoObject();
            user.data = new ExpandoObject();
            user.data.id = i;
            user.data.name = "User Name";
            var parsed = service.Parse(user);
        });
    }

    static void ExecuteSerial()
    {
        var service = new Service();
        for (int i = 0; i < Iterations; i++)
        {
            dynamic user = new ExpandoObject();
            user.data = new ExpandoObject();
            user.data.id = i;
            user.data.name = "User Name";
            var parsed = service.Parse(user);
        }
    }
}

public class Service
{
    public User Parse(dynamic dynamicUser)
    {
        if (dynamicUser.data != null)
        {
            return new User
            {
                Id = dynamicUser.data.id,
                Name = dynamicUser.data.name
            };
        }
        return null;
    }
}

public class User
{
    public int Id { get; set; }
    public string Name { get; set; }
}
于 2012-10-19T20:23:09.607 に答える
1

Here the tasks that you're doing are so simple, take so little time, and there are few enough of them, that the overhead of creating threads, breaking up the tasks, scheduling them, dealing with context switches, memory barriers, and all of that, is significant in comparison to the amount of productive work that you're doing. If you were doing work that took longer then the overhead of parallelizing it would be much less in comparison.

于 2012-10-19T20:19:51.000 に答える