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,一切都会好起来的。为什么(在哪里)会发生死锁?

SemaphoreSlim注意:在我使用 a而不是 a解决的原始代码中TaskCompletionSource,根本没有问题。我只想了解问题出在哪里。

4

2 回答 2

3

tcs.SetResult(null);在基础任务完成之前,调用Worker()不会返回(有关详细信息,请查看此问题)。在您的情况下,任务状态WaitingForActivation就是您遇到死锁的原因:

  1. 线程执行Worker()tcs.SetResult(null)调用阻塞。

  2. 线程执行Stop()_thread.Join()调用阻塞。

于 2017-12-20T09:12:27.283 回答
0

因为MainAsync()线程比另一个线程“更快”。而且您只控制任务而不是线程

在您的方法中MainAsync(),您等待方法StartAsync()完成其工作,然后启动线程。一旦方法StartAsync()完成其工作(创建并启动线程),该函数就会通知MainAsync()完成其工作。然后MainAsync()调用 Stop 方法。但是你的线程在哪里?它在没有任何控制的情况下并行运行,并试图完成它的工作。这不是死锁,任务和线程之间没有同步。

这就是为什么当你把 await Task.Delay(1)你的代码工作时,因为线程足够快,可以在任务结束之前完成工作(thread.join)。

于 2017-12-20T09:02:43.243 回答