私のコードでデッドロックの問題に直面しています。ありがたいことに、以下の例で問題を再現できました。通常の .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
、まったく問題はありません。問題がどこにあるかを理解したいだけです。