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