[ThreadPool]待機中の数を取得したい

Question

質問

ThreadPoolを利用した非同期アプリケーションを作成しています。
ThreadPoolの実行を待機している状態の数がいくつあるかを取得したいです。

現在のプログラム

using System;
using System.Threading;

namespace ThreadPoolTest
{
  class Program
  {
    static void MyThread(object i)
    {
      Console.WriteLine($"15秒待機開始 i = {(int)i}");
      Thread.Sleep(TimeSpan.FromSeconds(15));
      Console.WriteLine($"15秒待機終了 i = {(int)i}");
    }

    static void Main(string[] args)
    {
      ThreadPool.SetMinThreads(10, 10);
      ThreadPool.SetMaxThreads(10, 10);

      for (var i = 0; i < 1000; i++)
      {
        ThreadPool.GetAvailableThreads(out var availableWorkerThreads, out _);
        Console.WriteLine($"利用可能スレッド数（空きスレッド数） = {availableWorkerThreads}");
        // Console.WriteLine($"実行待機中の数 = ");

        ThreadPool.QueueUserWorkItem(new WaitCallback(MyThread), i);
        Thread.Sleep(1000);
      }
    }
  }
}

実行結果

利用可能スレッド数（空きスレッド数） = 10
15秒待機開始 i = 0
利用可能スレッド数（空きスレッド数） = 9
15秒待機開始 i = 1
利用可能スレッド数（空きスレッド数） = 8
15秒待機開始 i = 2
利用可能スレッド数（空きスレッド数） = 7
15秒待機開始 i = 3
利用可能スレッド数（空きスレッド数） = 6
15秒待機開始 i = 4
利用可能スレッド数（空きスレッド数） = 5
15秒待機開始 i = 5
利用可能スレッド数（空きスレッド数） = 4
15秒待機開始 i = 6
利用可能スレッド数（空きスレッド数） = 3
15秒待機開始 i = 7
利用可能スレッド数（空きスレッド数） = 2
15秒待機開始 i = 8
利用可能スレッド数（空きスレッド数） = 1
15秒待機開始 i = 9
利用可能スレッド数（空きスレッド数） = 0
利用可能スレッド数（空きスレッド数） = 0
利用可能スレッド数（空きスレッド数） = 0
利用可能スレッド数（空きスレッド数） = 0
利用可能スレッド数（空きスレッド数） = 0
15秒待機終了 i = 0
15秒待機開始 i = 10
利用可能スレッド数（空きスレッド数） = 0
15秒待機終了 i = 1
15秒待機開始 i = 11
利用可能スレッド数（空きスレッド数） = 0
15秒待機終了 i = 2
15秒待機開始 i = 12
利用可能スレッド数（空きスレッド数） = 0
15秒待機終了 i = 3
15秒待機開始 i = 13
利用可能スレッド数（空きスレッド数） = 0
15秒待機終了 i = 4
15秒待機開始 i = 14
利用可能スレッド数（空きスレッド数） = 0
15秒待機終了 i = 5
15秒待機開始 i = 15
利用可能スレッド数（空きスレッド数） = 0
15秒待機終了 i = 6
15秒待機開始 i = 16
利用可能スレッド数（空きスレッド数） = 0
15秒待機終了 i = 7
15秒待機開始 i = 17
利用可能スレッド数（空きスレッド数） = 0
15秒待機終了 i = 8
15秒待機開始 i = 18
利用可能スレッド数（空きスレッド数） = 0
15秒待機終了 i = 9
15秒待機開始 i = 19
利用可能スレッド数（空きスレッド数） = 0

試したこと

• MSDNを確認しましたが、欲しているメソッドはありませんでした。

https://docs.microsoft.com/ja-jp/dotnet/api/system.threading.threadpool?view=netcore-2.2

環境

• VisualStudio 2019
• .NET Core 2.2

Answer 1

下記のようにキューに積む時にカウンターをインクリメントして、処理開始したらデクリメントするのはどうでしょう？

using System;
using System.Threading;

namespace ThreadPoolTest
{
    class Program
    {
        static int WaitingThreadCount = 0;
        static void MyThread(object i)
        {
            Console.WriteLine($"15秒待機開始 i = {(int)i}");
            WaitingThreadCount--;
            Thread.Sleep(TimeSpan.FromSeconds(15));
            Console.WriteLine($"15秒待機終了 i = {(int)i}");
        }

        static void Main(string[] args)
        {
            ThreadPool.SetMinThreads(10, 10);
            ThreadPool.SetMaxThreads(10, 10);

            for (var i = 0; i < 1000; i++)
            {

                ThreadPool.GetAvailableThreads(out var availableWorkerThreads, out _);
                Console.WriteLine($"利用可能スレッド数（空きスレッド数） = {availableWorkerThreads}");
                Console.WriteLine($"実行待機中の数 = {WaitingThreadCount}");

                WaitingThreadCount++;
                ThreadPool.QueueUserWorkItem(new WaitCallback(MyThread), i);
                Thread.Sleep(1000);
            }
        }
    }
}

Comments

[退会済みユーザー]

なるほどですね…！
Thread, Taskあたりを調べていましたが純粋に実装する方法を失念しておりました。ありがとうございました。