SerialPortクラスのDataReceivedイベントが発生しなくなる

Question

現在複数のCOMポートを扱うプログラムを制作しています。
DataReceivedイベントの中で電文をすべて受信する為にThread.Sleepで待機しているのですが、
Thread.Sleepを入れると他のCOMポートのDataReceivedイベントが発生しなくなります。
どうやらスリープしている間発生しないということでもないようですが、スリープの秒数が長いほどイベントが発生しない可能性が高いです。
なぜこのようなことが起きるのか、どうすれば解決するのか皆目見当がつきません。どなたかご教示いただけますでしょうか。何卒よろしくお願いいたします。

下記ソースコードは２つのポートに接続し、定期的にデータを送信するプログラムです。SP1は送信後最大500ms秒間DataReceivedイベントが発生するか待機しメッセージを表示します。
SP2は定期的にデータを送信し、DataReceivedイベントが発生したタイミングでThread.Sleepを実行します。
両方接続先は何らかのデータを送信すると即座に文字列を返すポートに接続してテストを行いました。

該当のソースコード

using System;
using System.Diagnostics;
using System.IO.Ports;
using System.Threading;
using System.Threading.Tasks;

namespace SerialPortReceTest
{
    class Program
    {
        static SerialPort SP1 = new SerialPort("COM10",19200, Parity.Even,8, StopBits.One);
        static SerialPort SP2 = new SerialPort("COM12", 9600, Parity.None,8, StopBits.One);

        static bool responded = true;

        static void Main(string[] args)
        {


            SP1.DataReceived += SP1_DataReceived;
            SP2.DataReceived += SP2_DataReceived;

            Task task = Task.Factory.StartNew(() => {
                int timeOutMs = 500;
                Stopwatch sw = new Stopwatch();

                while (true)
                {

                    if (SP1.IsOpen)
                    {
                        responded = false;

                        byte[] buff = new byte[] { 0x31, 0x31, 0x31 };
                        SP1.Write(buff, 0, buff.Length);

                        sw.Start();
                        while (sw.ElapsedMilliseconds < timeOutMs && !responded)
                        {
                            Thread.Sleep(0);
                        }
                        sw.Reset();

                        if (responded)
                        {
                            Console.WriteLine("There response");
                        }
                        else
                        {
                            Console.WriteLine("No response ");
                        }

                    }

                    Thread.Sleep(20);

                }
            });

            Task task2 = Task.Factory.StartNew(() => {
                while (true)
                {
                    if (SP2.IsOpen)
                    {
                        byte[] buff = new byte[] { 0x31, 0x31, 0x31 };
                        SP2.Write(buff, 0, buff.Length);
                    }

                    Thread.Sleep(100);
                }
            });

            SP1.Open();
            SP2.Open();

            Console.ReadKey(true);
        }

        private static void SP1_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
            responded = true;
            SP1.DiscardInBuffer();
        }

        private static void SP2_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
            Console.WriteLine("sleep start");
            Thread.Sleep(100000);
            Console.WriteLine("sleep end");
            SP2.DiscardInBuffer();
        }

    }
}

スリープあり

sleep start
No response
There response
No response
There response
No response
No response
There response
No response
No response
No response
No response
No response
There response
No response
No response
No response
No response
No response
There response
No response
No response

スリープなし

There response
There response
There response
There response
There response
There response
There response
There response
There response
There response
There response
There response
There response

Comments

[ozwk]

再現しないと思って色々書きましたがミスってました。再現したのでちょっと見てみます。

[koao]

よろしくお願いいたします。

Answer 1

DataReceivedイベントハンドラが実行される際には、ハンドラはThreadPoolのキューに登録されます。
このプログラムでは、SP2_DataReceivedは、100ms毎に3個ずつキューに登録されることになります。
従って、100000msスリープしている間に、3000個分がThreadPoolのキューに登録されてます。

SP1_DataReceivedハンドラも、受信時にはThreadPoolのキューに登録されます。

ThreadPoolは、プロセスに1つしかなく、実際に利用できるスレッドが空いたら、キューから取り出して実行されます。

このプログラムで起きている現象は、SP2_DataReceivedがキューに溜まりすぎて、SP1_DataReceivedがディスパッチされていないのが原因と思われます。

Comments

[koao]

回答ありがとうございます。

スレッド プールの最小値に達するとタスクが完了するか、追加のスレッドが作成されるまで待機するようで、追加のスレッドを作成するペースが遅い為にこういう状態になったということみたいです。
スレッドプールの最小値を上げることで改善されました。