Согласно документу ThreadPoolExecutor (Java ThreadPoolExecutor ), если я создам службу-исполнитель следующим образом:
new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
и когда #threads > corePoolSize, простаивающие потоки будут уничтожены. Я хотел вызвать определенный код очистки приложения, когда ThreadPoolExecutor убивает любой поток. Я не смог получить четкий способ сделать это. Цените любую помощь. Заранее спасибо.
правильный способ сделать это — расширить Thread и запустить код очистки после возврата метода run(), например:
BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(50);
ThreadFactory threadFactory = new ThreadFactory() {
@Override
public Thread newThread(Runnable r) {
return new Thread(r) {
@Override
public void run() {
super.run();
//DO YOUR CLEANUP HERE
}
};
}
};
new ThreadPoolExecutor(1, 10, 10, TimeUnit.SECONDS, workQueue, threadFactory);
прерывание почти наверняка не будет вызвано в вашем сценарии, поскольку оно будет вызываться только при завершении работы активного исполнителя (и даже в этом случае не всегда).
вызывая очистку непосредственно после запуска, ваш код очистки вызывается прямо перед смертью потока (поток умирает после возврата метода run()).
interruptдля запуска очистки — это не то, что вам нужно. Когда рабочий поток уничтожается, ThreadPool просто отказывается от ссылки, но не обязательно вызывает прерывание. И наоборот: когда вызывается прерывание, это не означает, что поток уничтожается. - person Fildor schedule 03.08.2014