私はデッドロック問題に直面しています。ありがたいことに、私は以下の例で問題を再現できました。通常の.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
ボディの小さな遅延、すべてがうまくいく。 なぜデッドロックが発生するのですか?
注:元のコードではTaskCompletionSource
の代わりにSemaphoreSlim
を使用して解決しましたが、問題はまったくありません。私は問題がどこにあるのか理解したいだけです。
「タスク」と「スレッド」を混在させる理由は何ですか? – Groo
'var tcs = new TaskCompletionSource
@Grooオリジナルのコードには、タスクを混在させずにいくつかのジョブを実行する長時間実行スレッド(ワーカー)があります。しかし、最初の仕事が完了したときに完了するワーカー/スレッドを開始するために待たれている機能があります。 –