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

Question

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

*此处任务为非ui活动

null

• 我正在使用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的文档：

所有的请求都在一个工作线程上处理--它们可能需要多长时间（并且不会阻塞应用程序的主循环），但一次只会处理一个请求。

您应该重新构造所有内容并使用常规服务，在onStartCommand（）中提交任务，并在onDestroy（）中调用exec.shutdown（）。