我的活动有一个AsyncTask,其doInBackground方法可在下面看到.我必须向多个服务器发出多个搜索请求,并且为了加快执行速度,我使用了Java的ExecutorService来发出并发请求.
这可以正常工作,但是如果我调用AsyncTask.cancel(),我希望AsyncTask停止正在执行的所有操作并退出.方法为true的mayInterruptIfRunning参数.这在我的活动退出时需要停止任务的情况下很有用按下“返回”按钮.
我已经读过,调用AsyncTask的cancel()方法将阻止onPostExecute方法被调用,但是doInBackground将一直运行到完成为止.
有没有办法,我可以打断我的Callables并强迫他们停止正在执行的操作并停止AsyncTask.
为了简洁起见,我在这里发布了我的代码的简化版本,但是我有一堆Callables,而不仅仅是一个.
谢谢.
protected ArrayList<Result> doInBackground(final String... strQuery) {
ArrayList<Result> objResults = new ArrayList<Result>();
ExecutorService esrExecutor = Executors.newFixedThreadPool(2);
Set<Callable<ArrayList<Result>>> setCallables = new HashSet<Callable<ArrayList<Result>>>();
setCallables.add(new Callable<ArrayList<Result>>() {
public ArrayList<Result> call() throws Exception {
try {
MySearcher objSearcher = new MySearcher(Finder.this.objContext);
ArrayList<Result> objResults = new ArrayList<Result>();
objResults = objSearcher.doSearch(strQuery[0]);
return objResults;
} catch (Indexer.LoginException e) {
return null;
}
return null;
}
});
List<Future<ArrayList<Result>>> lstFutures;
try {
lstFutures = esrExecutor.invokeAll(setCallables);
for(Future<ArrayList<Result>> futFuture : lstFutures){
if (futFuture.get().isEmpty() == false)
objResults.addAll(futFuture.get());
}
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
esrExecutor.shutdown();
return objResults;
}
解决方法:
我认为一种解决方案是定期在doInBackground()方法中检查isCancelled()
,以检查AsyncTask是否已取消以及是否需要停止以前的操作.