Future task of ExecutorService not truly cancelling

by

I later hit breakpoints within the Callable procedure, as if the Future cancel() had no effect.

Future.cancel(true) removes a job that is in the queue and not yet running but if the job is already running it does the equivalent of Thread.interrupt() on the thread running the job. This sets the interrupt bit on the thread and causes any sleep(), wait(), and some other methods to throw InterruptedException.

It is important to realize that it does not stop the thread. You need to actively check for the interrupt flag in your thread loop or properly handle InterruptedException.

See my SO answer here for more details: How to suspend thread using thread’s id?

More Related Contents:

  1. How to wait for all threads to finish, using ExecutorService?
  2. ExecutorService that interrupts tasks after a timeout
  3. Executors.newCachedThreadPool() versus Executors.newFixedThreadPool()
  4. What are the advantages of using an ExecutorService?
  5. Java’s Fork/Join vs ExecutorService – when to use which?
  6. Impossible to make a cached thread pool with a size limit?
  7. What’s the difference between a Future and a Promise?
  8. ThreadPoolExecutor Block When Queue Is Full?
  9. Java ExecutorService: awaitTermination of all recursively created tasks
  10. How to use invokeAll() to let all thread pool do their task?
  11. ThreadPoolExecutor Block When its Queue Is Full?
  12. Java: ExecutorService that blocks on submission after a certain queue size [duplicate]
  13. How to pause/resume all threads in an ExecutorService in Java?
  14. Whether to use invokeAll or submit – java Executor service
  15. Controlling Task execution order with ExecutorService
  16. ExecutorCompletionService? Why do need one if we have invokeAll?
  17. What’s the difference between Thread start() and Runnable run()
  18. Volatile boolean vs AtomicBoolean
  19. What’s a monitor in Java?
  20. Turning an ExecutorService to daemon in Java
  21. How to use ConcurrentLinkedQueue?
  22. Java volatile reference vs. AtomicReference
  23. Allowing the this reference to escape
  24. Why does java.util.concurrent.ArrayBlockingQueue use ‘while’ loops instead of ‘if’ around calls to await()?
  25. FixedThreadPool vs CachedThreadPool: the lesser of two evils
  26. What is the most frequent concurrency issue you’ve encountered in Java? [closed]
  27. Not thread-safe Object publishing
  28. Dynamic Thread Pool
  29. notifyAll() throws IllegalMonitorStateException
  30. Will a chain of method calls (CompletableFuture API) execute asynchronously if the first method in a chain is asynchronous?

Leave a Comment