android - 单元测试用例中未调用 AsyncTask onPostExecute()

Question

我看过很多与此相关的帖子，但似乎没有一个与我遇到的问题相同。 GetBusinessRulesTask 扩展了 AsyncTask。当我在单元测试用例中执行此操作时，永远不会调用 onPostExecute() 。但是，如果我使用真实的客户端代码，则每次都会调用 onPostExecute() 。不确定我在这里做错了什么。

测试用例:

package com.x.android.test.api;

import java.util.concurrent.CountDownLatch;

import android.test.ActivityInstrumentationTestCase2;
import android.test.UiThreadTest;
import android.widget.Button;

import com.x.android.api.domain.businessrule.BusinessRules;
import com.x.android.api.exception.NetworkConnectionException;
import com.x.android.api.tasks.GetBusinessRulesTask;
import com.x.android.test.activity.SimpleActivity;

 public class GetBusinessRulesTaskTest
    extends
        ActivityInstrumentationTestCase2<SimpleActivity> {
SimpleActivity mActivity;
Button mButton;

public GetBusinessRulesTaskTest() {
    super("com.x.android.test.activity", SimpleActivity.class);
}

@Override
protected void setUp() throws Exception {
    super.setUp();
    mActivity = this.getActivity();
    mButton = (Button) mActivity
            .findViewById(com.x.android.test.activity.R.id.b1);
}

public void testPreconditions() {
    assertNotNull(mButton);
}

@UiThreadTest
public void testCallBack() throws Throwable {
    final CountDownLatch signal = new CountDownLatch(1);
    final GetBusinessRulesTask task = (GetBusinessRulesTask) new GetBusinessRulesTask(
            new GetBusinessRulesTask.Receiver<BusinessRules>() {
                @Override
                public void onReceiveResult(BusinessRules rules, Exception e) {
                    assertNotNull(rules);
                    assertNull(e);
                    signal.countDown();// notify the count down latch
                }
            });
    task.start(mActivity.getApplicationContext());
    try {
        signal.await();// wait for callback
    } catch (InterruptedException e1) {
        fail();
        e1.printStackTrace();
    }
}
}

OnPostExecute:

@Override
protected void onPostExecute(AsyncTaskResponse<O> response) {
    Log.d(TAG, "onPostExecuted");
    if (mReceiver != null) {
        mReceiver.onReceiveResult(response.getResponse(),   response.getException());
    }
}

DoInBackground:

@Override
protected AsyncTaskResponse<O> doInBackground(I... params) {
    Log.d(TAG, "doInBackgroundr");
    try {
        Uri uri = createUri(params);
        mBaseRequest = new GetLegacyRequest(uri);
        String json = mBaseRequest.executeRequest();
        O response = deserializeJson(json);
        Log.d(TAG, "Returning AsyncTaskResponse");
        return new AsyncTaskResponse<O>(response, null);
    } catch (Exception e) {
        Log.e(TAG, "Error", e);
        /*
        AsyncTaskResponse<O> maintenance = ReadBusinessControlledPropertiesTask.blockingCall(mServiceLocatorUrl);
        if(maintenance.getException() == null) {
            MaintenanceException mExcep = new MaintenanceException( maintenance.getResponse());
            if (mExcep.isUnderMaintenance())
                return new AsyncTaskResponse(null,mExcep);
        }*/
        return new AsyncTaskResponse<O>(null, e);
    }
}

启动方法()

public AsyncTask<Void, Void, AsyncTaskResponse<BusinessRules>> start(
        Context context) throws NetworkConnectionException {
    super.start(context);
    Log.d(TAG, "start");
    return execute();
}

找到问题。不要让你的 AsyncTask 最终化并将它放在 runnable 中。

修复:

public void testCallBack() throws Throwable {
    final CountDownLatch signal = new CountDownLatch(1);
    // Execute the async task on the UI thread! THIS IS KEY!
    runTestOnUiThread(new Runnable() {
    @Override
        public void run() {
            try {
              GetBusinessRulesTask task = (GetBusinessRulesTask)new GetBusinessRulesTask(new GetBusinessRulesTask.Receiver<BusinessRules>() {
                            @Override
                            public void onReceiveResult(
                                    BusinessRules rules, Exception e) {
                                assertNotNull(rules);
                                assertNull(e);
                                signal.countDown();// notify the count downlatch
                            }
                        });
                task.start(mActivity.getApplicationContext());
            } catch (Exception e) {
                Log.e(TAG, "ERROR", e);
                fail();
            }
        }
    });
    try {
        signal.await();// wait for callback
    } catch (InterruptedException e1) {
        fail();
        e1.printStackTrace();
    }
}

Answer 1

找到问题。不要让您的 AsyncTask 最终化并将其放入可运行对象中。

修复:

public void testCallBack() throws Throwable {
    final CountDownLatch signal = new CountDownLatch(1);
    // Execute the async task on the UI thread! THIS IS KEY!
    runTestOnUiThread(new Runnable() {
        @Override
        public void run() {
            try {
              GetBusinessRulesTask task = (GetBusinessRulesTask)new GetBusinessRulesTask(new GetBusinessRulesTask.Receiver<BusinessRules>() {
                            @Override
                            public void onReceiveResult(
                                    BusinessRules rules, Exception e) {
                                assertNotNull(rules);
                                assertNull(e);
                                signal.countDown();// notify the count downlatch
                            }
                        });
                task.start(mActivity.getApplicationContext());
            } catch (Exception e) {
                Log.e(TAG, "ERROR", e);
                fail();
            }
        }
    });
    try {
        signal.await();// wait for callback
    } catch (InterruptedException e1) {
        fail();
        e1.printStackTrace();
    }
}