如何在不阻塞主 UI 线程的情况下等待来自事件处理程序的返回值



所以我有这种方法,它使用库生成一个外部网页,以允许用户输入他们的Facebook凭据进行验证。输入后,我们将根据该用户帐户创建一个配置文件并将其保存到数据库中。一旦我们将其保存到数据库,我们期望一个布尔值来表示该帐户是否唯一。我们需要某种方法来等待数据库完成其所有工作,然后再继续执行。

我尝试了几种不同的方法,包括在新线程上完成所有工作(由于所有 UI 都需要在主线程上,因此无法正常工作)以及使用 AutoResetEvent 等待 auth.Completed 事件触发。但是当使用它时,它通常会阻塞线程,甚至不会向用户显示我们的外部网页。

使事情变得更加复杂的是,试图在不超越自己的情况下处理所有不同的事件。因此,首先我们需要等待auth.Completed触发,然后从该事件内部我们需要等待异步request.GetResponseAsync().ContinueWith<Task<bool>>(async t => ...事件完成,最后等待数据库完成其任务并以某种方式将返回值一直推回调用过程。

截至目前,此代码将执行所有所需的功能,但将返回 false,因为我们没有等待任何事件触发。

public bool LoginFacebook(bool isLinkedAccount)
    {
#if __IOS__
        UIKit.UIWindow window = UIKit.UIApplication.SharedApplication.KeyWindow;
        UIKit.UIViewController viewController = window.RootViewController;
#endif
        var auth = new OAuth2Authenticator(
                              clientId: "***********",
                              scope: "email",
                              authorizeUrl: new Uri("https://m.facebook.com/dialog/oauth/"),
                              redirectUrl: new Uri("http://www.facebook.com/connect/login_success.html")
                              );
#if __ANDROID__
        Forms.Context.StartActivity(auth.GetUI(Android.App.Application.Context));
#elif __IOS__
        if (viewController != null)
        {
            while (viewController.PresentedViewController != null)
                viewController = viewController.PresentedViewController;
            viewController.PresentViewController(auth.GetUI(), true, null);
        }
#endif
        // If authorization succeeds or is canceled, .Completed will be fired.
        auth.AllowCancel = true;
        auth.Completed += (sender, eventArgs) =>
        {
#if __IOS__
            viewController.DismissViewController(true, null);
#endif
            if (eventArgs.IsAuthenticated)
            {
                var request = new OAuth2Request("GET", new Uri("https://graph.facebook.com/me"), null, eventArgs.Account);
                request.GetResponseAsync().ContinueWith<Task<bool>>(async t =>
                {
                    if (t.IsFaulted)
                        Console.WriteLine("Error: " + t.Exception.InnerException.Message);
                    else
                    {
                        try
                        {
                            string content = t.Result.GetResponseText();
                            Console.WriteLine(content);
                            JObject user = JsonConvert.DeserializeObject<JObject>(content);
                            Facebook profile = new Facebook();
                            profile.uuid = user["id"].ToString();
                            profile.firstname = user["first_name"].ToString();
                            profile.lastname = user["last_name"].ToString();
                            profile.email = user["email"].ToString();
                            profile.url = user["link"].ToString();
                            //Get picture
                            profile.photo = "https://graph.facebook.com/" + profile.uuid + "/picture?type=large";
                            if (!isLinkedAccount)
                            {
                                //App.AnimateLoading(LoadingImage, OverlayImage, LoadingMessage);
                                return await DatabaseInstance.InsertSocialProfile(SocialNetworks.Facebook, profile, true);
                            }
                            else
                            {
                                await DatabaseInstance.LinkSocialAccountToProfile(App.UserProfile, profile, SocialNetworks.Facebook);
                                return true;
                            }
                        }
                        catch (Exception e)
                        {
                            Console.WriteLine(e.ToString());
                        }
                    }
                    return false;
                });
            }
        };
        return false;
    }
可以使用

TaskCompletionSource来表示可等待的任务,以便在事件处理程序和async方法的其余部分之间进行协商。

为了简洁明了,我从您的示例中修剪了所有#ifdef代码,只关注核心。考虑到这一点,如下所示:

public async bool LoginFacebook(bool isLinkedAccount)
{
    var auth = new OAuth2Authenticator(
                          clientId: "***********",
                          scope: "email",
                          authorizeUrl: new Uri("https://m.facebook.com/dialog/oauth/"),
                          redirectUrl: new Uri("http://www.facebook.com/connect/login_success.html")
                          );
    // If authorization succeeds or is canceled, .Completed will be fired.
    auth.AllowCancel = true;
    TaskCompletionSource<bool> completionSource = new TaskCompletionSource<bool>();
    auth.Completed += (sender, eventArgs) =>
    {
        completionSource.SetResult(eventArgs.IsAuthenticated);
    };
    if (!(await completionSource.Task))
    {
        return false;
    }
    var request = new OAuth2Request("GET", new Uri("https://graph.facebook.com/me"), null, eventArgs.Account);
    var t = await request.GetResponseAsync();
    if (t.IsFaulted)
    {
        Console.WriteLine("Error: " + t.Exception.InnerException.Message);
        return false;
    }
    try
    {
        string content = t.Result.GetResponseText();
        Console.WriteLine(content);
        JObject user = JsonConvert.DeserializeObject<JObject>(content);
        Facebook profile = new Facebook();
        profile.uuid = user["id"].ToString();
        profile.firstname = user["first_name"].ToString();
        profile.lastname = user["last_name"].ToString();
        profile.email = user["email"].ToString();
        profile.url = user["link"].ToString();
        //Get picture
        profile.photo = "https://graph.facebook.com/" + profile.uuid + "/picture?type=large";
        if (!isLinkedAccount)
        {
            return await DatabaseInstance.InsertSocialProfile(SocialNetworks.Facebook, profile, true);
        }
        else
        {
            await DatabaseInstance.LinkSocialAccountToProfile(App.UserProfile, profile, SocialNetworks.Facebook);
            return true;
        }
    }
    catch (Exception e)
    {
        Console.WriteLine(e.ToString());
        return false;
    }
}

当然,随着此方法更改为async方法,调用方现在可以异步等待结果,从而避免阻塞主线程。

当然,缺乏一个好的、最少的、完整的代码示例作为开始,上面只是浏览器编辑的代码。我没有编译它,更不用说测试它了。但以上是一般想法。我假设您可以将该概念合并到您的实际代码中。

相关内容

  • 没有找到相关文章

最新更新