3

我在整个代码中使用异步/等待模式。但是，有一个 API 使用了基于事件的异步模式。我在 MSDN 和几个 StackOverflow 上阅读过答案，这样做的方法是使用 TaskCompletionSource。

我的代码：

public static Task<string> Process(Stream data)
{
    var client = new ServiceClient();
    var tcs = new TaskCompletionSource<string>();

    client.OnResult += (sender, e) =>
    {
        tcs.SetResult(e.Result);
    };

    client.OnError += (sender, e) =>
    {
        tcs.SetException(new Exception(e.ErrorMessage));
    };

    client.Send(data);

    return tcs.Task;
}

并称为：

string result = await Process(data);

或者，为了测试：

string result = Process(data).Result;

该方法总是很快返回，但没有一个事件被触发。

如果我添加 tcs.Task.Await(); 就在 return 语句之前，它可以工作，但这并没有提供我想要的异步行为。

我已经与我在互联网上看到的各种样本进行了比较，但没有发现任何差异。

4

2 回答 2

8

问题在于，在您的Process方法终止后，您的ServiceClient局部变量有资格进行垃圾收集，并且可能在事件触发之前被收集，因此存在竞争条件。

为了避免这种情况，我将定义ProcessAsync为类型的扩展方法：

public static class ServiceClientExtensions
{
    public static Task<string> ProcessAsync(this ServiceClient client, Stream data)
    {
        var tcs = new TaskCompletionSource<string>();

        EventHandler resultHandler = null;
        resultHandler = (sender, e) => 
        {
            client.OnResult -= resultHandler;
            tcs.SetResult(e.Result);
        }

        EventHandler errorHandler = null;
        errorHandler = (sender, e) =>
        {
            client.OnError -= errorHandler;
            tcs.SetException(new Exception(e.ErrorMessage));
        };

        client.OnResult += resultHandler;
        client.OnError += errorHandler;

        client.Send(data);
        return tcs.Task;
    }
}

并像这样消费它：

public async Task ProcessAsync()
{
    var client = new ServiceClient();
    string result = await client.ProcessAsync(stream);
}

编辑： @usr 指出，通常，IO 操作应该是那些保持对谁调用它们的引用的操作，而我们在这里看到的情况并非如此。ServiceClient我同意他的观点，这种行为有点特殊，可能表明该对象存在某种设计/实现问题。如果可能的话，我建议查看实现，看看是否有任何可能导致引用无法保持根深蒂固的东西。

于 2015-12-05T14:35:08.573 回答
-2

我想我应该回答这个问题。

public static Task<string> Process(Stream data)
{
    var handle = new AutoResetEvent(false);
    var client = new ServiceClient();
    var tcs = new TaskCompletionSource<string>();

    client.OnResult += (sender, e) =>
    {
        tcs.SetResult(e.Result);
        handle.Set();
    };

    client.OnError += (sender, e) =>
    {
        tcs.SetException(new Exception(e.ErrorMessage));
        handle.Set();
    };

    client.Send(data);

    handle.WaitOne(10000); // wait 10 secondds for results
    return tcs.Task;
}
于 2015-12-05T14:33:04.197 回答