java - 在服务中实现线程池

Question

我目前正在努力实现一个服务，当请求时，它会在多个并行线程上执行一些工作。

我的实现基于 ThreadPoolExecutor 类以及 LinkedBlockingQueue。

作为基本规则，一旦所有任务都完成并且队列中没有待处理的任务，我想停止该服务(尽管稍后可以再次启动该服务并遵循相同的逻辑)。

我已经能够使用下面的代码达到预期的结果，但我不确定这种方法是否正确。

public class TestService extends Service {
    // Sets the initial threadpool size to 3
    private static final int CORE_POOL_SIZE = 3;

    // Sets the maximum threadpool size to 3
    private static final int MAXIMUM_POOL_SIZE = 3;

    // Sets the amount of time an idle thread will wait for a task before terminating
    private static final int KEEP_ALIVE_TIME = 1;

    // Sets the Time Unit to seconds
    private static final TimeUnit KEEP_ALIVE_TIME_UNIT = TimeUnit.SECONDS;

    // A queue of Runnables for the uploading pool
    private final LinkedBlockingQueue<Runnable> uploadQueue = new LinkedBlockingQueue<Runnable>();

    // A managed pool of background upload threads
    private final ThreadPoolExecutor uploadThreadPool = new ThreadPoolExecutor(
            CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE_TIME, KEEP_ALIVE_TIME_UNIT,
            uploadQueue) {

        @Override
        protected void afterExecute(Runnable r, Throwable t) {
            super.afterExecute(r, t);

            if (getActiveCount() == 1 && getQueue().size() == 0) {
                // we're the last Runnable around + queue is empty, service can be
                // safely stopped.
                TestService.this.stopSelf();
            }
        }
    };

    @Override
    public IBinder onBind(Intent intent) {
        return null;
    }

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        // execute a new Runnable
        uploadThreadPool.execute(new TestRunnable());

        /**
         * Indicating that if Android has to kill off this service (i.e. low memory),
         * it should not restart it once conditions improve.
         */
        return START_NOT_STICKY;
    }

    @Override
    public void onDestroy() {
        uploadThreadPool.shutdownNow();
        uploadQueue.clear();

        super.onDestroy();
    }
}

所以我有一些我还不确定的事情。

1. 假设 onDestroy 被调用，是否可以安全地假设我的实现将中断所有正在运行的线程并安全地清除未决任务而不会以某种方式中断 ThreadPoolExecutor 类实现？我问的原因是因为队列与执行程序相关联，也许 shutdownNow 是异步的并且取决于队列的状态。有更好的方法吗？

2. 我在 onDestroy 中实现这个逻辑是否正确？根据我的经验，在某些情况下服务会被终止(即内存不足)并且不会调用此回调。我是否也应该在其他地方执行类似的方法？

3. 将我的队列和执行器类成员声明为静态会更好吗？ -- 如@TheTwo所述 “调用关闭后无法重新使用执行器” .

4. ThreadPoolExecutor 类需要一个 BlockingQueue，使用其他类型的 BlockingQueue 实现(即 >ArrayBlockingQueue)?

5. 关于我当前检测队列何时为空且没有更多待处理任务的方式(特别是在 afterExecute 回调中)——这是执行此操作的最佳方式吗？或者我能否得到队列为空且任务已完成的指示？

感谢任何帮助!

Answer 1

我认为您正在尝试实现一项服务，该服务引入了许多问题，但没有解决任何问题。实际上，您将调用代码减少了一行——执行程序的创建——但剥夺了对其进行精细控制的能力。调度许多任务没有任何好处，因为操作系统的线程调度程序已经解决了这个问题。此外，恶意调用者可以通过添加足够的 while(true) sleep(100); 循环来破坏其他几个程序。

关于您的问题:

1. 您无法确保所有线程都被正确中断，因为没有办法中断未正确监视中断标志的线程。 while(true) ; 不能被中断，除非被 System.exit() 中断。理论上您可以停止一个线程，但此功能已被弃用是有原因的，因为它会使实际任务处于未完成/未完成状态(即让 TCP 连接保持半开状态)。

2. 不，您没有正确实现它。一旦任务离开他的队列，就会简单地消失在空白中，然后一旦调用关闭，就不能重新使用 Excecutor。所以你至少需要在服务启动时创建一个新的 Excecutor 实例，你真的应该弄清楚如何处理剩余的任务。

3. 没有，因为 2.

4. 列表类型的优缺点取决于您的用例。 ArrayList 在增长/​​收缩时成本较高，但在索引特定元素 (indexOf) 时成本较低，而链表则相反。由于您的队列总是添加到尾部，除了第一个元素之外不关心任何其他元素，并且它经常增长/收缩，因此链表是最佳选择。

5. 您根本不应该以这种方式停止任务，因为线程的执行顺序是未定义的。在最坏的情况下，您的调用程序每次都被中断，直到服务执行完毕，这将导致服务无缘无故地不断启动和停止，同时白白浪费大量处理时间。为什么你甚至想停止服务？如果它无事可做，它只会使用几个字节的内存。