java – 在服务中实现线程池

我的实现是基于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();
    }
}

所以我有一些我还不确定的东西.

>假设onDestroy被调用,假设我的实现会中断所有正在运行的线程,并安全地清除待处理的任务,而不会中断ThreadPoolExecutor类实现,这是否可以安全？我问的原因是因为队列与执行程序相关联,也可能是shutdownNow是异步的,具体取决于队列的状态.有更好的做法吗？
我是否正确地在内部实现这个逻辑？根据我的经验,在某些情况下,服务被杀死(即低内存),并且此回调未被调用.我应该在其他地方执行类似的做法吗？
>最好是申报我的队列执行者类成员为静态？ – 如@TheTwo所述“一旦关闭被调用,就不能重新使用Excecutor”.
ThreadPoolExecutor类期待一个BlockingQueue,使用其他类型的BlockingQueue实现(即ArrayBlockingQueue)的优缺点是什么？
关于我当前检测队列为空的方式没有更多的待处理任务(特别是在执行回调之后) – 这是最好的做法吗？或者我可以得到一个指示,队列是空的,任务是以另一种方式完成的？

欣赏任何帮助！