为什么无休止的任务阻塞

Question

我正在启动2个任务，没有await-ing，其中一个是依赖于另一个。我试图理解为什么以下剪辑代码阻塞。

public class Tasks {
        EventWaitHandle handle = new EventWaitHandle(false, EventResetMode.ManualReset);

        public async Task Job1() {
            Console.WriteLine("Finished job1");
            handle.Set();
        }

        public async Task Job2() {
            handle.WaitOne();
            Console.WriteLine("Doing Job2 work");
        }
    }

    class Program {
        static async Task Main(string[] args) {

                Tasks seq = new Tasks();
                var t2 =seq.Job2();
                var t1 =seq.Job1();

                await Task.WhenAll(t1, t2);
                Console.WriteLine("finished both");
        }
    }

如果我为我的任务创建CPU-bound任务，它的工作原理：

var t2=Task.Run(seq.Job2);
var t1=Task.Run(seq.Job1);

我还尝试将两个任务放在主线程的单独任务中，它仍然阻止：

var bigtask=Task.Run(async()=>{
                         var t2 =seq.Job2();
                         var t1 =seq.Job1();
                     });

如果我在没有等待的情况下启动任务，它与启动新的CPU-bound任务几乎不一样吗？ （Task.Run）

Answer 1

看看你的编译器警告;他们会告诉你究竟出了什么问题。具体来说，你使用没有async的await，所以这些方法将同步运行。

Task.Run在线程池线程上执行该方法，这会阻止它同步运行。

如果我在没有等待的情况下启动任务，它与[使用Task.Run]几乎不一样？

Every async method starts executing synchronously; await是它可以异步行为的点。

async本身不使用任何线程（或线程池）;它更像是回调的更高级语法。 Task.Run确实使用了线程池。

---

要解决你的潜在问题（让一个任务等待另一个任务），最简单的方法是将从Task返回的Job1传递给Job2方法，并让Job2 await完成任务。如果那是不可能的，那么你需要一种异步信号（不是像EventWaitHandle这样的阻塞信号）。一次性异步信号是TaskCompletionSource<T>; SemaphoreSlim还支持异步等待;更复杂的协调原语是我的AsyncEx library的一部分。

Answer 2

声明方法“async”不会自动使您的代码成为多线程。您可以假设您的代码将同步运行，直到“等待”某些内容为止。

这里的问题是Job2将永远不会返回，因此您的代码将被卡住。但是，例如（而不是实际的解决方案），如果你做了这样的事情：

            public async Task Job2()
            {
                await Task.Delay(1000);
                handle.WaitOne();
                Console.WriteLine("Doing Job2 work");
            }

你的程序实际上会退出，因为一旦等待延迟，该函数将变为异步并返回给调用者。

在TPL（async / await）中通常应该避免使用像“EventWaitHandle / ManualResetEvent”这样的同步原语，因为它们会物理地阻塞线程，而不是释放它并等待回调。

这是一个实际的解决方案：

    public class Tasks
    {
        SemaphoreSlim semaphore = new SemaphoreSlim(0);

        public async Task Job1()
        {
            Console.WriteLine("Finished job1");
            semaphore.Release();
        }

        public async Task Job2()
        {
            await semaphore.WaitAsync();
            Console.WriteLine("Doing Job2 work");
        }
    }

    class Program
    {
        static async Task Main(string[] args)
        {

            Tasks seq = new Tasks();
            var t2 = seq.Job2();
            var t1 = seq.Job1();

            await Task.WhenAll(t1, t2);
            Console.WriteLine("finished both");
        }
    }