How to stop all runnable thread in java executor class?

by

The shutDown() method simply prevents additional tasks from being scheduled. Instead, you could call shutDownNow() and check for thread interruption in your Runnable.

// in your Runnable...
if (Thread.interrupted()) {
  // Executor has probably asked us to stop
}

An example, based on your code, might be:

final ExecutorService executor = Executors.newFixedThreadPool(1);
executor.submit(new Runnable() {
  public void run() {
    try {
      Thread.sleep(20 * 1000);
    } catch (InterruptedException e) {
      System.out.println("Interrupted, so exiting.");
    }
  }
});

if (executor.awaitTermination(10, TimeUnit.SECONDS)) {
  System.out.println("task completed");
} else {
  System.out.println("Forcing shutdown...");
  executor.shutdownNow();
}

More Related Contents:

  1. How to wait for all threads to finish, using ExecutorService?
  2. ExecutorService, how to wait for all tasks to finish
  3. ExecutorService that interrupts tasks after a timeout
  4. Handling exceptions from Java ExecutorService tasks
  5. How to properly shutdown java ExecutorService
  6. Executors.newCachedThreadPool() versus Executors.newFixedThreadPool()
  7. Choose between ExecutorService’s submit and ExecutorService’s execute
  8. How to properly use Java Executor?
  9. What are the advantages of using an ExecutorService?
  10. Java’s Fork/Join vs ExecutorService – when to use which?
  11. Turning an ExecutorService to daemon in Java
  12. Is ExecutorService (specifically ThreadPoolExecutor) thread safe?
  13. Impossible to make a cached thread pool with a size limit?
  14. ThreadPoolExecutor Block When Queue Is Full?
  15. Java ExecutorService: awaitTermination of all recursively created tasks
  16. How to use invokeAll() to let all thread pool do their task?
  17. How to shutdown an ExecutorService?
  18. FixedThreadPool vs CachedThreadPool: the lesser of two evils
  19. ThreadPoolExecutor Block When its Queue Is Full?
  20. ExecutorService vs Casual Thread Spawner
  21. How to pause/resume all threads in an ExecutorService in Java?
  22. Java Executors: how can I stop submitted tasks?
  23. Removing all queued tasks of an ThreadPoolExecutor
  24. Shutdown ExecutorService gracefully in webapp?
  25. Dynamic Thread Pool
  26. ExecutorCompletionService? Why do need one if we have invokeAll?
  27. What operations in Java are considered atomic?
  28. Java Executors: how can I set task priority?
  29. When does the main thread stop in Java?
  30. RejectedExecutionException inside single executor service

Leave a Comment