如何让异步任务在 Android 中完成

Question

我正在开发一个从网络检索数据、将它们存储到设备然后读取它们的应用程序。 问题是，我在异步任务中获取数据。我的应用程序在尝试向用户显示数据之前没有让任务完成。 我试过 task.get() 但没有结果（它就停在那里）。

这是我的任务：

public GetOptionsTask(XMLPortalGetOptions request) {
        super(request);
    }
    protected void onCancelled(){
        // TODO afficher message pas d'options sur le disque
    }
    @Override
    public void handleError(Transaction transaction) {
        // TODO afficher message pas d'options sur le disque
    }
    @Override
    public void handleSuccess(Transaction transaction) {
        saveOptions(transaction.getResponse());
        request = null;
        Log.d(OptionsManager.class.getName(), this.getStatus().toString());
    }

此任务是我的自定义异步任务的一个实例：

protected BaseXMLTransaction request;

public abstract void handleError(Transaction transaction);
public abstract void handleSuccess(Transaction transaction);
public TransactionTask(BaseXMLTransaction request){
    this.request = request;
}
@Override
protected Void doInBackground(Void... params) {
    try {
        Log.i(TransactionTask.class.getName(), "Doing in background");
        SocketHandler.sendTransaction(this, request.getRequest());
    } catch (SocketHandlerNotConfiguredException e) {
        Log.e(TransactionTask.class.getName(), "SocketHandler's parameters were not set.");
    }
    return null;
}
@Override
public void transactionResult(Transaction transaction) {
    switch (transaction.getCode()) {
        case ERROR:
            Log.e(TransactionTask.class.getName(), "ERROR !!!");
            handleError(transaction);
            break;
        case NO_CLIENT:
            Log.e(TransactionTask.class.getName(), "No Client Error");
            handleError(transaction);
            break;
        case NO_SERVER:
            Log.e(TransactionTask.class.getName(), "No Server Error");
            handleError(transaction);
            break;
        case OLD_VERSION:
            Log.e(TransactionTask.class.getName(), "Old Version");
            handleError(transaction);
            break;
        case TIMEOUT:
            Log.e(TransactionTask.class.getName(), "Transaction Timeout");
            handleError(transaction);
            break;
        case SUCCESS:
            Log.i(TransactionTask.class.getName(), "Transaction Success");
            handleSuccess(transaction);
    }
}

我真的不知道该怎么办......执行速度很快，get 没有做任何事情，因为我没有返回任何我猜的东西。

Answer 1

onPostExecute(Result)，在后台计算完成后在 UI 线程上调用。后台计算的结果作为参数传递给这一步。

@Override
protected void onPostExecute(String result) {

}

Answer 2

private class DownloadFilesTask extends AsyncTask<URL, Integer, Long> {
     protected Long doInBackground(URL... urls) {
         int count = urls.length;
         long totalSize = 0;
         for (int i = 0; i < count; i++) {
             totalSize += Downloader.downloadFile(urls[i]);
             publishProgress((int) ((i / (float) count) * 100));
             // Escape early if cancel() is called
             if (isCancelled()) break;
         }
         return totalSize;
     }

     protected void onProgressUpdate(Integer... progress) {
         setProgressPercent(progress[0]);
     }

     protected void onPostExecute(Long result) {
         showDialog("Downloaded " + result + " bytes");
     }
 }

然后这样称呼它：

new DownloadFilesTask().execute(url1, url2, url3);

Answer 3

我使用接口作为委托来执行此操作。这是一个例子：

在我的主要活动中，我有一个 onClick 监听器来触发我的异步调用，还有一个监听器在调用完成后进行处理。

private void enableLocationButton(){
    locationButton = (Button) findViewById(R.id.locationButton);
    locationButton.setEnabled(true);
    locationButton.setOnClickListener(new View.OnClickListener() {
        @Override
        public void onClick(View view) {
            Intent intent = new Intent(MainActivity.this, selectLocationActivity.class);
            intent.putExtra("serverURL",server.getWebServerAddressField());
            startActivityForResult(intent, 200);
        }
    });

}

 @Override
protected void onActivityResult(int requestCode,int resultCode, Intent data){
    if(resultCode == RESULT_OK) {
        switch (requestCode){
            case 100:
                processServerResponse((PmsWebServer) data.getBundleExtra("server").get("server"));
                break;
            case 200:
                processLocationResponse((PmsDataSource)data.getBundleExtra("location").get("location"));
            default:processError();
        }
    }else{
        processError();
    }
}

在 selectLocationActivity 的某处，我调用了 Async 调用并处理了响应，请注意，该类实现了 Async 调用中使用的接口。

public class selectLocationActivity extends ListActivity implements SoapServiceInterface{

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_location_select);
    chosenServer = this.removeURLHeader(getIntent().getStringExtra("serverURL"));
    this.retrieveLocationOptionsByServer(chosenServer);
}

private void retrieveLocationOptionsByServer(String server) {
    Map<String,Object> parms = new HashMap<String,Object>();
    parms.put(WEB_SERVER_NAME,server);
    SoapServiceObject service = new SoapServiceObject(Services.SERVICE_DETAILS,parms);
    callTheService(service);
}

private void callTheService(SoapServiceObject service){
    SoapServiceHelper helper = new SoapServiceHelper();
    helper.delegate = thisActivity;
    helper.execute(service);
}

@Override
public void serviceCallComplete(SoapObject response){
    this.createClickableListOnScreen(response);
} 
//...more code...//
}

serviceCallComplete 由 asyncTask 启动。以下是该任务的代码

public class SoapServiceHelper extends AsyncTask<SoapServiceObject, Void, SoapObject>{
public SoapServiceInterface delegate = null;
private Integer RETRY_COUNT = 0;
private final Integer MAX_RETRY_COUNT = 2;

protected SoapObject doInBackground(SoapServiceObject... args){
    SoapServiceObject service = args[0];
    try{
        service.callTheService();
    }catch(Exception e){
        System.out.println("An error occurred calling the service\n" + e.getMessage());
    }
    return service.getResponse();
    //return callDateTimeService();
}

protected void onPostExecute(SoapObject result){
    delegate.serviceCallComplete((SoapObject)(result.getProperty(0)));
} 
}

最后是界面

public interface SoapServiceInterface {

    public void serviceCallComplete(SoapObject response);
}

我知道我正在从结果中直接在屏幕上显示一些内容，只需将那部分替换为保存并读取；）

Answer 4

该任务的一个特点是将内容保存到单例中。我设法使用保存在 onResume() 的单例中的网络信息来调用这些方法。当线程结束时，它会进入 onResume，一切正常！