4

我写了一个类，它的一系列实例打算从 AsyncTask 中调用，它会从方法 runReport() 返回一个结果。它创建了一个工作线程就好了，但由于某种原因它不执行 Callable 的 call() 方法。我究竟做错了什么？

//Problem: doStuff() never gets called, even though the worker thread gets created.

@Override
public ReportResult runReport() throws InterruptedException, ExecutionException {
    Callable<ReportResult> report = new Callable<ReportResult>() {

        @Override
        public ReportResult call() throws Exception {
            doStuff();
            ...
            return new ReportResult(varWrittenByMethod);
        }
    };
    FutureTask<ReportResult> result = new FutureTask<ReportResult>(report);

    //I tried a few of these ExecutorService factory methods, with the same result.
    //I only made my own ThreadFactory to verify the worker was created
    ExecutorService es = Executors.newSingleThreadExecutor(new ThreadFact());
    es.submit(report);

    ReportResult finalResult = result.get();
    es.shutdownNow();
    return finalResult;
}


private class ThreadFact implements ThreadFactory{

    @Override
    public Thread newThread(Runnable r) {
        Log.d(TAG, "Created worker Thread");
        return new Thread(r);
    }

}

据我所知，我必须在自己的线程中作为 FutureTask 执行此操作，因为它需要执行以下操作（除了返回之外，所有这些都在 doStuff() 内部）：

  • 进行一些同步设置（AsyncTask 将其保持在 UI 线程之外）
  • 调用 Looper.prepare()
  • 注册一个监听器
  • 调用 Looper.loop()，在一段时间内捕获来自监听器的一些回调。
  • 当我有足够的数据点时，在侦听器回调中调用 Looper.myLooper().quit()
  • 返回结果

我愿意接受更好的方法来做到这一点。我最初让 AsyncTask 进行此调用，然后在其线程上运行 Looper.loop()，但我无法处理这些对象的队列，因为我需要在返回结果之前从侦听器调用 Looper.myLooper.quit() ，这会不可逆地毒化线程的消息队列。

4

2 回答 2

4

您的线程工厂不会将传递的 Runnable 传播到创建的线程。在您的 ThreadFactory 中，尝试：

return new Thread(r);

此外，您应该使用提交方法返回的 FutureTask，而不是您明确创建的。例如

FutureTask<ReportResult> result = es.submit(report);
ReportResult finalResult = result.get();
于 2012-12-13T01:53:14.750 回答
2

请注意，您可能会后悔从 AsyncTask 执行此级别的工作，因为 AsyncTask 中的线程将在 Activity 生命周期更改期间被终止。最好在 IntentService 中进行异步设置。如果你不需要 Looper()，你可以使用普通线程而不是 HandlerThreads。

于 2012-12-13T02:07:44.440 回答