将事件转换为异步调用

本文关键字:异步 调用 转换 事件 | 更新日期: 2023-09-27 18:29:36

我正在包装一个库以供自己使用。为了得到某个财产,我需要等待一个事件。我正试图将其封装到一个异步调用中。

基本上,我想转

void Prepare()
{
    foo = new Foo();
    foo.Initialized += OnFooInit;
    foo.Start();
}
string Bar
{
    return foo.Bar;  // Only available after OnFooInit has been called.
}

进入这个

async string GetBarAsync()
{
    foo = new Foo();
    foo.Initialized += OnFooInit;
    foo.Start();
    // Wait for OnFooInit to be called and run, but don't know how
    return foo.Bar;
}

如何才能最好地做到这一点?我可以循环等待,但我正在尝试找到更好的方法,例如使用Monitor.Pulse()、AutoResetEvent或其他方法。

将事件转换为异步调用

这就是TaskCompletionSource发挥作用的地方。这里几乎没有空间容纳新的async关键字。示例:

Task<string> GetBarAsync()
{
    TaskCompletionSource<string> resultCompletionSource = new TaskCompletionSource<string>();
    foo = new Foo();
    foo.Initialized += OnFooInit;
    foo.Initialized += delegate
    {
        resultCompletionSource.SetResult(foo.Bar);
    };
    foo.Start();
    return resultCompletionSource.Task;
}

示例使用(具有高级异步)

async void PrintBar()
{
    // we can use await here since bar returns a Task of string
    string bar = await GetBarAsync();
    Console.WriteLine(bar);
}