-2

我仍在尝试围绕异步进行思考,我想知道为什么以下代码会导致死锁。我的用例是这样的:我有一个服务接口,它试图抽象出服务是如何实现的。其中一项服务是基于 OAuth 的 Web 服务。服务接口有一个方法Connect(),任何使用该接口的人都必须在使用它之前执行该方法。

在我的客户端,我创建了具体的服务对象并调用Connect()了我的视图构造函数(这是一个原型,所以我只是想获得一个概念证明)。在基于 OAuth 的服务中,连接调用需要检索访问令牌,因此它(尝试)异步执行此操作。但是,此Connect()调用永远不会返回,并且应用程序已死锁(但 UI 处于活动状态)。我猜我搞砸了并试图在某个地方同步使用我的客户端,但我不确定在哪里。

控制

public class MainWindow
{
    public MainWindow()
    {
        InitializeComponent();
        _webService = new OAuthBasedWebService();
        _webService.ShowAuthorizationPage += _webService_ShowAuthorizationPage; // this is defined on the concrete object -- i know, bad design
        _webService.Connect();
    }
}

基于 OAuth 的网络服务

public class OAuthBasedWebService()
{
    private OAuthWrapper _wrapper;

    public async void Connect()
    {
        var uri = await _wrapper.GetAuthorizationUri();
        OnShowAuthorizationPage(uri);
    }
}

internal class OAuthWrapper
{
    public async Task<Uri> GetAuthorizationUri()
    {
        var uri = await _consumer.GetAuthorizationUriAsync();
        return uri;
    }
}

internal class OAuthConsumer
{
    public async Task<Uri> GetAuthorizationUriAsync()
    {
        using (var client = new HttpClient())
        {
            client.BaseAddress = "webservicebaseaddress";
            var content = new FormUrlEncodedContent(new []
            {
                CreateParameter("oauth_consumer_key", "consumerkey"),
                CreateParameter("oauth_consumer_secret", "consumersecret")
                // etc., etc.
            });

            var response = await client.PostAsync("/method_path", content).ConfigureAwait(false);
            var responseContent = await response.Content.ReadAsStringAsync().ConfigureAwait(false);

            // parse authorization uri from responseContent
            return authorizationUri;
        }
    }
}

我知道设计需要做一些工作,但我试图弄清楚为什么会出现僵局。我猜这是因为_webService.Connect()没有被异步调用,但我也不能那样await做,因为它不返回任何东西,程序的其余部分也不依赖它。

4

1 回答 1

1

我不确定您为什么在这里使用事件,如果问题只是因为您无法使构造函数“异步”,那么只需将 conect 调用移至另一个方法:

public class MainWindow
{
    public MainWindow()
    {
        InitializeComponent();
        Init();
    }

    public async void Init(){

        _webService = new OAuthBasedWebService();

        Uri uri=await _webService.Connect();
         _webService_ShowAuthorizationPage(uri);
    }
}


public class OAuthBasedWebService()
{
    private OAuthWrapper _wrapper;

    public async Task<Uri> Connect()
    {
        return await _wrapper.GetAuthorizationUri();

    }
}
于 2013-09-26T18:23:54.597 回答