0

Microsoft HPC で単純に設計されたコードをテストしようとしています。ジョブがすべてのコードを完了していないようです。ただし、私のテスト方法が間違っている可能性があります。いくつかのチェックポイントを印刷しているだけです。コードは次のとおりです。

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

class S
{
    static void Main()
    {
        pcount = Environment.ProcessorCount;
        Console.WriteLine("Proc count = " + pcount);
        ThreadPool.SetMinThreads(4, -1);
        ThreadPool.SetMaxThreads(4, -1);

      //  System.Threading.Thread.Sleep(20000);

        Console.WriteLine("check point 0 ");
        t1 = new Task(A, 1);
        t2 = new Task(A, 2);
        t3 = new Task(A, 3);
        t4 = new Task(A, 4);

        Console.WriteLine("Starting t1 " + t1.Id.ToString());
        t1.Start();
        Console.WriteLine("Starting t2 " + t2.Id.ToString());
        t2.Start();
        Console.WriteLine("Starting t3 " + t3.Id.ToString());
        t3.Start();
        Console.WriteLine("Starting t4 " + t4.Id.ToString());
        t4.Start();

        //  Console.ReadLine();
    }

    static void A(object o)
    {
        Console.WriteLine("check point A ");
        B(o);
    }
    static void B(object o)
    {
        int temp = (int)o;
        Console.WriteLine("check point B ");
        if (temp == 1)
        {
            C(o);
        }
        else
        {
            F(o);
        }
    }
    static void C(object o)
    {
        Console.WriteLine("check point C ");
        D(o);
    }
    static void D(object o)
    {
        int temp = (int)o;
        Console.WriteLine("check point D " + temp);

        if (temp == 2)
        {
            F(o);
        }
        else
        {
            E(o);
        }
    }
    static void E(object o)
    {
        Console.WriteLine("check point E ");

    }
    static void F(object o)
    {
        Console.WriteLine("check point F ");
        G(o);
    }
    static void G(object o)
    {
        Console.WriteLine("check point G ");

    }



    static Task t1, t2, t3, t4;

    static int pcount;
}

ジョブ出力では、最後まで印刷されていません。プリントアウトは任意の時点でランダムに終了します (ランダム関数内)。了解しました。実行は印刷よりも高速であるため、すべてを印刷できない場合があります (可能な説明)。しかし、ブレークポイントを配置してプロセスにアタッチしてデバッグしようとすると、コードの最初の部分でしかブレークポイントにヒットしません。テストプリントアウトと同じ範囲を打っているように見えます。任意のポイントでブレークポイントに到達できるように、コードが最後まで実行されるようにするにはどうすればよいですか?

4

1 に答える 1

1

ATaskは、いわゆるバックグラウンド スレッドで実行するように設計されています。つまり、メイン スレッドが終了すると、バックグラウンド スレッドも終了します。したがって、メソッドが完了するとすぐにMain()、すべてのスレッド (したがってすべてのタスク) が終了し、プログラムが終了します。

解決策は、タスクが完了するのを待つことです。

static void Main()
{
    pcount = Environment.ProcessorCount;
    Console.WriteLine("Proc count = " + pcount);
    ThreadPool.SetMinThreads(4, -1);
    ThreadPool.SetMaxThreads(4, -1);

  //  System.Threading.Thread.Sleep(20000);

    Console.WriteLine("check point 0 ");
    t1 = new Task(A, 1);
    t2 = new Task(A, 2);
    t3 = new Task(A, 3);
    t4 = new Task(A, 4);

    Console.WriteLine("Starting t1 " + t1.Id.ToString());
    t1.Start();
    Console.WriteLine("Starting t2 " + t2.Id.ToString());
    t2.Start();
    Console.WriteLine("Starting t3 " + t3.Id.ToString());
    t3.Start();
    Console.WriteLine("Starting t4 " + t4.Id.ToString());
    t4.Start();

    //  Console.ReadLine();

    t1.Wait();
    t2.Wait();
    t3.Wait();
    t4.Wait();
}
于 2013-05-23T23:58:12.683 に答える