java – 在服务中实现线程池

前端之家收集整理的这篇文章主要介绍了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)的优缺点是什么?
关于我当前检测队列为空的方式没有更多的待处理任务(特别是在执行回调之后) – 这是最好的做法吗?或者我可以得到一个指示,队列是空的,任务是以另一种方式完成的?

欣赏任何帮助!

解决方法

我想你正在试图实现一个服务,它引入了很多问题,但是没有解决.有效地,您将调用代码减少一行 – 创建执行程序 – 但是消除了精细控制它的能力.在安排许多任务时没有任何好处,因为这已经由OS的线程调度程序解决了.另外一个恶意的呼叫者可以通过添加足够的时间(true)sleep(100)来打破其他几个程序;循环.

关于你的问题:

>您无法确保所有线程都被正确中断,因为无法中断未正确观看中断标志的线程.一会儿(真)除了System.exit()外,不能中断.理论上你可以停止一个线程,但是由于这个原因可以使实际的任务处于不完整/未完成的状态(即,使TCP连接半开),这个特性已被弃用.>不,你没有正确的实现.对于一旦离开的任务,他的队列将简单地在空白中消失,然后一旦关闭调用,就不能重新使用Excecutor.所以你至少需要在服务启动时创建一个新的Excecutor实例,你真的应该知道如何处理剩余的任务.>不,因为2.>列表类型的优缺点取决于用例.一个ArrayList在成长/收缩时成本较高,但在索引特定元素(indexOf)时成本较低,而链表相反.由于您的队列总是添加到尾部,不关心任何其他元素,而是第一个,并且它经常增长/缩小,链表是最佳选择.>你不应该这样完成任务,因为线程的执行顺序是未定义的.在最坏的情况下,您的呼叫程序每次中断,直到服务完成执行,这将导致服务不断启动&停止没有特别的原因,同时浪费了大量的处理时间.为什么你甚至想停止服务?如果它无关紧要,除了使用几个字节的内存之外它不会做任何事情.

猜你在找的Java相关文章