异步函数中的TaskCompletionSource

Question

我有这样一个函数：

public async Task<bool> DoSomething()
{
   var tcs = new TaskCompletionSource<bool>();

   // Here is the problem. I need to keep this line because I wait on something asynchronously, but the function must return bool and I can't just return tcs.Task
   while(something)
      await Task.Delay(100);

   someobject.somevent += () => {
      // do some sht
      tcs.SetResult(true);
   }

   // it doesn't work
   return tcs.Task;
}

这只是一个虚假的代码，但我有真正的情况下，我需要它。我想让DoSomething保持异步，但我也想让Task.Delay/睡眠在其中。如何在仅返回任务的非异步函数中做到这一点？

更新：

这是可行的：

class Program
    {
        static TaskCompletionSource<bool> tcs = new TaskCompletionSource<bool>();


        static Task<bool> Test()
        {
           // tcs = new TaskCompletionSource<bool>();
            Task.Factory.StartNew(() =>
            {
                Console.WriteLine("Waiting...");
                Thread.Sleep(5000);
                Console.WriteLine("Setting result");
                if(tcs.TrySetResult(true))
                    Console.WriteLine("Result has been set");


            });

            return tcs.Task;
        }

        static async Task Test2()
        {
            Console.WriteLine("Starting awaiting");
            var result = await Test();
            Console.WriteLine(result.ToString());
        }

        static void Main(string[] args)
        {


            Test2();

            Console.ReadKey(false);

        }
    }

但这并不是

static async Task<bool> Test()
{
   // tcs = new TaskCompletionSource<bool>();
    Task.Factory.StartNew(() =>
    {
        Console.WriteLine("Waiting...");
        Thread.Sleep(5000);
        Console.WriteLine("Setting result");
        if(tcs.TrySetResult(true))
            Console.WriteLine("Result has been set");


    });


    return await tcs.Task;
}

更糟糕的是，我已经在我的windows窗体应用程序中测试了它，等待来自System.Threading....dll的tcs.Task导致奇怪的崩溃

Answer 1

如果我理解正确(这很棘手，因为你的问题不那么容易理解)，你可以按如下方式重申：

public async Task<bool> DoSomething()
{
   var tcs = new TaskCompletionSource<bool>();
   someobject.somevent += () => {
      // do some sht
      tcs.SetResult(true);
   }

   return await tcs.Task;
}

Answer 2

如果你将事件触发转换成Task的逻辑转换成它自己的方法，整个事情就会变得更加优雅。

public static Task<bool> WhenSomeEvent(this SomeObject someobject)
{
    var tcs = new TaskCompletionSource<bool>();
    Action handler = null;
    handler = () =>
    {
        tcs.SetResult(true);
        someobject.SomeEvent -= handler;
    };
    someobject.SomeEvent += handler;
    return tcs.Task;
}

这允许您单独编写业务逻辑，而无需混合将事件转换为Task的所有逻辑

public async Task<bool> DoSomething()
{
    while(something)
        await Task.Delay(100);

    return await someobject.WhenSomeEvent();
}