简单线程管理-Java-Android

Question

我有一个应用程序，当用户要求过滤图像时会生成一个新线程。

这是我唯一要做的任务，所有任务都同等重要。

如果我请求太多并发线程（我最多希望有9个），则线程管理器将抛出 RejectedExecutionException 。

在那一刻我要做的是；

// Manage Concurrent Tasks
private Queue<AsyncTask<Bitmap,Integer,Integer>> tasks = new LinkedList<AsyncTask<Bitmap,Integer,Integer>>();

@Override
public int remainingSize() {
    return tasks.size();
}

@Override
public void addTask(AsyncTask<Bitmap, Integer, Integer> task) {
    try{
        task.execute(currentThumbnail);
        while(!tasks.isEmpty()){
            task = tasks.remove();
            task.execute(currentThumbnail);
        }
    } catch (RejectedExecutionException r){
        Log.i(TAG,"Caught RejectedExecutionException Exception - Adding task to Queue");
        tasks.add(task);
    }
}

只需将被拒绝的任务添加到队列中，下次启动线程时，将检查队列以查看是否存在积压。

显而易见的问题是，如果最终任务在第一次尝试时被拒绝，它将永远不会重新启动（直到不再需要它为止）。

我只是想知道是否有一个简单的模型可以用来管理这种事情。我需要完成任务时通知队列。

Answer 1

这样做的原因RejectedExecutionException是因为AsyncTask实现了自己的线程池（根据Martelli先生的回答），但是一个线程池最多可同时执行10个任务。他们为什么有这个限制，我不知道。

因此，一种可能性是您可以克隆AsyncTask，提高限制（或不受限制，也可以使用LinkedBlockingQueue）并使用克隆。然后，也许将更改作为补丁提交，以AsyncTask供将来的Android版本使用。

单击此处运行Google代码搜索AsyncTask-第一个匹配项应该是实现。

如果您只是想增加限制，请调整MAXIMUM_POOL_SIZE为可能需要的大小。如果要不受限制，请使用零参数LinkedBlockingQueue构造函数，而不是当前使用的构造函数。AFAICT，其余代码可能保持不变。