提交给执行器的FutureTask不运行

Question

我编写了一个类，它的一系列实例将从AsyncTask调用，它将从方法runReport（）返回一个结果。它很好地创建了一个工作线程，但由于某种原因，它不执行可调用的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);
    }

}

null

我愿意用更好的方法来做这件事。我最初让AsyncTask进行这个调用，然后在它的线程上运行looper.loop()，但是我无法处理这些对象的队列，因为我需要在返回结果之前从侦听器调用looper.mylooper.quit（），这会不可逆转地毒害线程的消息队列。

Answer 1

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

return new Thread(r);

此外，您应该使用submit方法返回的FutureTask，而不是您显式创建的FutureTask。例如。

FutureTask<ReportResult> result = es.submit(report);
ReportResult finalResult = result.get();