没有回调接口的 AsyncTask

Question

我正在尝试解决这个问题：我有一个从 AsyncTask 扩展的类，它执行一些 http 方法，如下所示：

    public class RESTManager extends AsyncTask<Object, Object, String>
{
    public RESTManager(String url, MethodTypes myMethod,ICallbackHandler hndl, String     restMethod)
    {
        initialize();
    }

    private String doGET()
    {
    }

    private String doPOST()
    {
    }

    @Override
    protected String doInBackground(Object... params)
    {

    }

    @Override
    protected void onPostExecute(String result)
    {
    }

}

所以，从 Activity 我做这个：

RESTManager webService = new WSManager(URL, MethodTypes.REGISTER, params, this, WSManager.GET_METHOD);
webService.execute();

然后activity在callbak方法中接收响应（因为activity实现了这个接口）：

public void response(String response)
{
    // some process
}

这工作正常，但我的问题是我希望答案出现在对某个函数的同一次调用中，然后该函数调用 .execute 方法，例如。

// This is a new class
public class MyWebServices()
{
    public User getUser(int id)
    {
        User myUser;

        RESTManager webService = new WSManager(URL, MethodTypes.REGISTER, params, this, WSManager.GET_METHOD);
        webService.execute();

        // BUT I WANT TO RETURN FROM HERE THE CALL FROM THE ACTIVITY....LIKE

        return myUser;
    }
}

所以从活动来看，这将是：

MyWebServices myService = new MyWebServices();
User usr = myService.getUser(id);

希望不明白我试图描述的内容，谢谢！

Answer 1

您想要的会导致 UI 阻塞。 Android 不允许您这样做。网络调用应该是异步的，所以方法是错误的。处理response() 方法。

UPD：阻止用户界面会导致“应用程序无响应对话框”，这会惹恼用户。另外，如果网络调用失败怎么办？还是要等半个小时才能完成？

Answer 2

学会爱上回调:)

您不能在不阻塞 UI 线程的情况下应用您提到的模式（在后台执行、等待结果、返回值）。

最简单的就是简单的实现onPostExecute()方法，在REST调用完成后调用你想做的事情。但是，如果您想向系统的其他部分公开一个干净的接口，您可以变得更复杂。

首先阅读observer pattern。可以这样想：REST 调用的完成是一个事件，对该事件感兴趣的代码可以注册以在它完成时（异步）得到通知。你可以这样做，我让你的 AsyncTask 像这样实现，

AsyncTask myTask = new AsyncTask<...>() {
    public interface Callback {
        void onComplete();
        void onFailure();
    }

    private Set<Callback> callbacks = new HashSet<Callback>();

    public void addObserver(Callback cb) { callbacks.add(cb); }

    @Override
    protected String doInBackground(Object... params)
    {
        // whatever
    }

    @Override
    protected void onPostExecute(String result)
    {
        if (success) {
            for (Callback cb: callbacks) {
                cb.onComplete();
            }
        } else {
            for (Callback cb: callbacks) {
                cb.onFailure();
            }       
        }
    }
}

现在，这个接口的消费者做了类似的事情，

MyTask mt = new MyTask();
mt.addObserver(new MyTask.Callback() { 
    @Override
    public void onComplete() {
        // do whatever you want to do when the task completes successfully
    }

    @Override
    public void onFailure() {
        // ...
    }
}

mt.execute();