Removing all queued tasks of an ThreadPoolExecutor

by

I used to work on an app with long running threads. We do this at shutdown,

BlockingQueue<Runnable> queue = threadPool.getQueue();
List<Runnable> list = new ArrayList<Runnable>();
int tasks = queue.drainTo(list);

The list is saved to a file. On startup, the list is added back to the pool so we don’t lose any jobs.

More Related Contents:

  1. ExecutorService, how to wait for all tasks to finish
  2. Turning an ExecutorService to daemon in Java
  3. ThreadPoolExecutor Block When Queue Is Full?
  4. FixedThreadPool vs CachedThreadPool: the lesser of two evils
  5. ThreadPoolExecutor Block When its Queue Is Full?
  6. Dynamic Thread Pool
  7. ExecutorService that interrupts tasks after a timeout
  8. Handling exceptions from Java ExecutorService tasks
  9. How to properly shutdown java ExecutorService
  10. Executors.newCachedThreadPool() versus Executors.newFixedThreadPool()
  11. Naming threads and thread-pools of ExecutorService
  12. Choose between ExecutorService’s submit and ExecutorService’s execute
  13. How to properly use Java Executor?
  14. What are the advantages of using an ExecutorService?
  15. Java’s Fork/Join vs ExecutorService – when to use which?
  16. Is ExecutorService (specifically ThreadPoolExecutor) thread safe?
  17. Impossible to make a cached thread pool with a size limit?
  18. How are Threads allocated to handle Servlet request?
  19. Java ExecutorService: awaitTermination of all recursively created tasks
  20. How to use invokeAll() to let all thread pool do their task?
  21. When should we use Java’s Thread over Executor?
  22. How to shutdown an ExecutorService?
  23. How to stop all runnable thread in java executor class?
  24. How Threadpool re-use Threads and how it works
  25. Propagating ThreadLocal to a new Thread fetched from a ExecutorService
  26. ExecutorService vs Casual Thread Spawner
  27. Java Executors: how can I stop submitted tasks?
  28. Shutdown ExecutorService gracefully in webapp?
  29. What is optimum thread pool size for simple program running cpu based tasks in Java
  30. ExecutorCompletionService? Why do need one if we have invokeAll?

Leave a Comment