質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

ただいまの
回答率

90.50%

  • C#

    9065questions

    C#はマルチパラダイムプログラミング言語の1つで、命令形・宣言型・関数型・ジェネリック型・コンポーネント指向・オブジェクティブ指向のプログラミング開発すべてに対応しています。

Dictionaryへのアクセスがデッドロックになる

解決済

回答 1

投稿

  • 評価
  • クリップ 0
  • VIEW 1,142

tkow

score 1177

お世話になっております。

非同期処理でList<Dictionary<ParamType,double>>にParamTypeごとの計算処理を行いたいと思っています。

           var adjust_params = Enumerable.Range(0, node_depth).Select(index =>
                     new Dictionary<SamplingKey, double>() {
                        {ParamType.a,0},
                        {ParamType.b,0},
                        {ParamType.c,0},

           ).ToArray();

            Parallel.ForEach(nodes.Values, node =>
            {
                int gen_counts = node.tables.AsParallel().Sum(data => data.generate)

                var ab_task = Task.Run(() =>
                {
                    double y1 = 0;
                    double y2 = 0;
                    for (int i = 1; i < gen_counts; i++)
                    {
                        double y = generateOrNot();
                        y1 += 1 - y;
                        y2 += y;
                    }
                    return new { a = y1, b = y2 };
                });

                double c = Math.Log(node.price);

                lock(adjust_params[node.depth]){
                    adjust_params[node.depth][ParamType.a] += ab_task.Result.a;      
                    adjust_params[node.depth][ParamType.b] += ab_task.Result.b;
                    adjust_params[node.depth][ParamType.b] += c;
                 }
            });


この処理ではnodeの数が多すぎるとlock(adjust_params[node.depth])でデッドロックになります。恐らく、二つ以上のスレッドが運悪くクリティカルセクションに侵入してしまうとadjust_paramの読み込みがロックされてデッドロック状態になってしまうようです。nodeがそこまで多くなければ問題なかったのですが、CPU使用率が100%になったりするので、遅延発生で同時にクリティカルセクションに侵入してしまうnodeがあるのかと思っています。やってることは重たい処理を並列化して、nodeごとの合計を出したいだけなのですが、どのように改善するのがよいでしょうか。

アドバイスいただける方いましたらよろしくお願いいたします。

  • 気になる質問をクリップする

    クリップした質問は、後からいつでもマイページで確認できます。

    またクリップした質問に回答があった際、通知やメールを受け取ることができます。

    クリップを取り消します

  • 良い質問の評価を上げる

    以下のような質問は評価を上げましょう

    • 質問内容が明確
    • 自分も答えを知りたい
    • 質問者以外のユーザにも役立つ

    評価が高い質問は、TOPページの「注目」タブのフィードに表示されやすくなります。

    質問の評価を上げたことを取り消します

  • 評価を下げられる数の上限に達しました

    評価を下げることができません

    • 1日5回まで評価を下げられます
    • 1日に1ユーザに対して2回まで評価を下げられます

    質問の評価を下げる

    teratailでは下記のような質問を「具体的に困っていることがない質問」、「サイトポリシーに違反する質問」と定義し、推奨していません。

    • プログラミングに関係のない質問
    • やってほしいことだけを記載した丸投げの質問
    • 問題・課題が含まれていない質問
    • 意図的に内容が抹消された質問
    • 広告と受け取られるような投稿

    評価が下がると、TOPページの「アクティブ」「注目」タブのフィードに表示されにくくなります。

    質問の評価を下げたことを取り消します

    この機能は開放されていません

    評価を下げる条件を満たしてません

    評価を下げる理由を選択してください

    詳細な説明はこちら

    上記に当てはまらず、質問内容が明確になっていない質問には「情報の追加・修正依頼」機能からコメントをしてください。

    質問の評価を下げる機能の利用条件

    この機能を利用するためには、以下の事項を行う必要があります。

回答 1

checkベストアンサー

0

この手の計算処理は、generateOrNotが相当時間かからない限りパラレルにしたりTask.Runした方がむしろ遅そうではありますが…

とりあえず以下のように書き直した場合ロックされますか?

Task.Run(() =>
{
    double y1 = 0;
    double y2 = 0;
    for (int i = 1; i < gen_counts; i++)
    {
        double y = generateOrNot();
        y1 += 1 - y;
        y2 += y;
    }
    return new { a = y1, b = y2 };
}).ContinueWith(x =>
{
    // ここでa, bを外に出す必要性は無いはずだが、こちらの方が分かりやすいし安全なので。
    double a = x.Result.a;
    double b = x.Result.b;
    double c = Math.Log(node.price);
    lock (adjust_params[node.depth])
    {
        adjust_params[node.depth][ParamType.a] += a;
        adjust_params[node.depth][ParamType.b] += b;
        adjust_params[node.depth][ParamType.b] += c;
    }
});

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

  • 2017/01/26 14:22 編集

    こちらサンプルは実際のコードを書き直してかなり簡略化していますが、実際は内部でもっと重たいタスクが走っています。generateOrNodeはものすごく重たい処理と考えて差し支えないです。とりあえずやってみますね。

    追記
    一応計算回るようになりました!ありがとうございます!ただ、理屈があまり整理できていないのですが、同期処理になるのでContinueWithはThreadごとには排他制御になるとは思うのですが、それでもうまくいくのであれば並行スレッドじゃなくてメインスレッドに投げるからですかね?(同期スレッドで実行されるならlock)も消せる気がしました。ありがとうございます。

    キャンセル

  • 2017/01/26 15:03

    ふと思ったのですが、adjust_paramの値の取得処理が途中でなければDictionaryではなくクラスにして
    class ParamValue
    {
    public double a;
    public double b;
    public double c;
    }
    とすれば、ロック不要でアトミックな操作が直接できたりしませんか?

    キャンセル

  • 2017/01/26 15:23 編集

    あぁ確かにそうですね...。なんか頭でっかちになってました。ありがとうございます。
    haru666さんのコードがadjust_paramをロックしてたのは外での書き出し読み出しを考慮してるからですよね?
    ありがとうございます。
    追記 
    ContinueWithは同じスレッド上でタスク後の処理を継続するようなので、ほかのスレッドからも書き込みがあるので、やっぱロックも入れないとだめなきがしました。上手くいってるのは、いったん同じスレッドで同期をすることで、ほかスレッド上でロック前の同期待ちが発生する確率が小さくなるからな気がしています。
    また、思い出したのですが、dictionaryにしたのはadjust_paramsの要素は本来は構造体でロックの時にlistのインデックスごとにロックするのができなくてDictionaryにした経緯があったと思います。classにすれば同じようにロックできると思いますが、ロック省くのは無理そうなきがしました。

    キャンセル

同じタグがついた質問を見る

  • C#

    9065questions

    C#はマルチパラダイムプログラミング言語の1つで、命令形・宣言型・関数型・ジェネリック型・コンポーネント指向・オブジェクティブ指向のプログラミング開発すべてに対応しています。