任务等待不返回结果

Question

我正在尝试编写一个使用 Task 和 TaskCompletion 的函数。

我的问题是登录后没有返回结果。我之前使用过类似的代码，它正在工作。我不知道造成这种情况的原因。

public async Task<byte[]> Sign(byte[] documentContent)
{
    var service = new SignServiceWrapper("https://example.com?wsdl");
    var loginResult = await Task.Run(() => service.Login(loginRequest));

    //....
}

还有我的 SignServiceWrapper 类

public class SignServiceWrapper
{
    private static string _webServiceUrl;
    private  BrokerClientClient client;

    public SignServiceWrapper(string webServiceUrl)
    {
        _webServiceUrl = webServiceUrl;
    }

    public Task<loginResponse> Login(loginRequest request)
    {
        var tcs = new TaskCompletionSource<loginResponse>();

        ClientGenerator.WebServiceUrl = _webServiceUrl;

        ClientGenerator.InitializeService(); 
        client = ClientGenerator.ServiceClient;   

        client.loginCompleted += (sender, loginResult) =>
        {
            if (loginResult.Error != null)
                tcs.SetException(loginResult.Error);
            else
                tcs.TrySetResult(loginResult.Result);
        };    

        client.loginAsync(request);                

        return tcs.Task;
    }

    // ...
}

如果我这样调用我的登录函数，它会起作用

var loginResult = Task.Run(() => service.Login(loginRequest));
loginResult.Wait();

我知道有一种死锁，但我不知道如何在这里解决这个问题以及哪个对象。

Answer 1

更改var loginResult = await Task.Run(() =>service.Login(loginRequest)); 致var loginResult = await service.Login(loginRequest);

Answer 2

这是一个有效的.NET Fiddle。

我认为你的.Login 方法做得太多了。我注意到的第一件事（并且只能想象它是如何实现的）是静态ClientGenerator，它具有静态可变状态。这是令人震惊的和非常具体的代码气味。我很想看看客户端本身是什么样子以及它是如何实现的，因为这肯定有助于更好地回答这个问题。

根据您迄今为止分享的内容（并假设 client.loginAsync 返回 Task<loginResponse>），我想说您可以执行以下操作：

public class SignServiceWrapper
{
    private static string _webServiceUrl;
    private  BrokerClientClient client;

    public SignServiceWrapper(string webServiceUrl)
    {
        _webServiceUrl = webServiceUrl;
    }

    public Task<loginResponse> LoginAsync(loginRequest request)
    {
        ClientGenerator.WebServiceUrl = _webServiceUrl;
        ClientGenerator.InitializeService();
        client = ClientGenerator.ServiceClient;

        return client.loginAsync(request);
    }

    // ...
}

然后你可以这样消费它：

public async Task<byte[]> Sign(byte[] documentContent)
{
    var service = new SignServiceWrapper("https://example.com?wsdl");
    var loginResult = await service.LoginAsync(loginRequest);

    //...
}

如果client.loginAsync 没有返回您要查找的内容，那么您需要通过something similar to your current approach 处理此问题。或者，如果您被锁定在 event-based async pattern，您还有其他考虑因素 - 例如您是否要支持取消、IsBusy、进度、增量结果，以及您是否有能力让事件 args 继承 @987654333 @等……

最后一个考虑因素，如果 client.loginAsync 是 Task 返回，即使它不返回 loginResponse 你也需要像这样等待它：

public async Task<loginResponse> Login(loginRequest request)
{
    var tcs = new TaskCompletionSource<loginResponse>();

    ClientGenerator.WebServiceUrl = _webServiceUrl;
    ClientGenerator.InitializeService();
    client = ClientGenerator.ServiceClient;
    client.loginCompleted += (sender, loginResult) =>
    {
        if (loginResult.Error != null)
            tcs.SetException(loginResult.Error);
        else
            tcs.TrySetResult(loginResult.Result);
    };    

    await client.loginAsync(request);                

    return tcs.Task;
}

更新

在与 OP 讨论后，.NET Fiddle 似乎符合他的需求。