ExecutorService 并在等待其他任务完成时在关机后接受新任务

Question

请为 android 应用程序提出一个解决方案，用户可以通过单击按钮请求执行任务。

*这里的任务是非ui活动

• 我需要允许用户执行多个请求
• 在多个任务执行期间，任务执行器应该等待完成所有任务。
• 当多个任务中的任何任务完成并且任务执行器正在等待其他任务完成时，如果用户请求其他任务 任务，所以我应该被接受和执行。
• 此任务应在 android 服务中执行，因此在应用程序退出时它不应终止。

我的表现如何：

• 我正在使用 ExcutorService & ExecutorCompletionService 它会抛出错误，因为任务执行器是 等待其他任务完成，然后如果用户请求其他任务

java.util.concurrent.RejectedExecutionException: 任务 java.util.concurrent.ExecutorCompletionService$QueueingFuture@4198abe8 从 java.util.concurrent.ThreadPoolExecutor@41caf8f8 被拒绝 [正在关闭，池大小 = 1，活动线程 = 1，排队任务= 0，完成的任务 = 1]

public int onStartCommand(Intent intent, int flags, int startId) {
        if (mIsAlreadyRunning) {
            MyTask task = new MyTask(++count, intent);
            mEcs.submit(task);
        }
        return super.onStartCommand(intent, flags, startId);
    }

protected void onHandleIntent(Intent intent) {
        if (mIsAlreadyRunning) {
            return;
        }
        mIsAlreadyRunning = true;
        final Collection<MyTask> tasks = mTasks;

        MyTask yt1 = new MyTask(count, intent);
        tasks.add(yt1);

        // wait for finish
        for (MyTask t : tasks) {
             mEcs.submit(t);
        }

        int n = tasks.size();
        for (int i = 0; i < n; ++i) {
            NoResultType r;
            try {
                r = mEcs.take().get();

            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
        }

        mExec.shutdown();

        try {
            mExec.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

    }

谢谢。

Answer 1

您没有正确使用 IntentService。它给出了错误，因为您在执行程序调用了 shutdown() 时提交了另一个任务。

IntentService 文档：

所有请求都在单个工作线程上处理——它们可能被视为 只要有必要（并且不会阻塞应用程序的主循环）， 但一次只会处理一个请求。

关于 IntentService 的 onStartCommand()：

您不应为您的 IntentService 覆盖此方法。

您应该重组所有内容并使用常规服务，在 onStartCommand() 中提交任务，并在 onDestroy() 中调用 exec.shutdown()。