5

私のコードでデッドロックの問題に直面しています。ありがたいことに、以下の例で問題を再現できました。通常の .Net Core 2.0 コンソール アプリケーションとして実行します。

class Class2
{

    static void Main(string[] args)
    {
        Task.Run(MainAsync);
        Console.WriteLine("Press any key...");
        Console.ReadKey();
    }

    static async Task MainAsync()
    {
        await StartAsync();
        //await Task.Delay(1);  //a little delay makes it working
        Stop();
    }


    static async Task StartAsync()
    {
        var tcs = new TaskCompletionSource<object>();
        StartCore(tcs);
        await tcs.Task;
    }


    static void StartCore(TaskCompletionSource<object> tcs)
    {
        _cts = new CancellationTokenSource();
        _thread = new Thread(Worker);
        _thread.Start(tcs);
    }


    static Thread _thread;
    static CancellationTokenSource _cts;


    static void Worker(object state)
    {
        Console.WriteLine("entering worker");
        Thread.Sleep(100);  //some work

        var tcs = (TaskCompletionSource<object>)state;
        tcs.SetResult(null);

        Console.WriteLine("entering loop");
        while (_cts.IsCancellationRequested == false)
        {
            Thread.Sleep(100);  //some work
        }
        Console.WriteLine("exiting worker");
    }


    static void Stop()
    {
        Console.WriteLine("entering stop");
        _cts.Cancel();
        _thread.Join();
        Console.WriteLine("exiting stop");
    }

}

私が期待するのは、次のような完全なシーケンスです。

Press any key...
entering worker
entering loop
entering stop
exiting worker
exiting stop

ただし、実際のシーケンスはThread.Join呼び出しで停止します。

Press any key...
entering worker
entering stop

MainAsync最後に、本体に小さな遅延を挿入すると、すべてがうまくいきます。なぜ (どこで) デッドロックが発生するのか?

注: 元のコードでは、 a のSemaphoreSlim代わりに aを使用して解決しましたがTaskCompletionSource、まったく問題はありません。問題がどこにあるかを理解したいだけです。

4

2 に答える 2