ExecutorService that interrupts tasks after a timeout

by

You can use a ScheduledExecutorService for this. First you would submit it only once to begin immediately and retain the future that is created. After that you can submit a new task that would cancel the retained future after some period of time.

 ScheduledExecutorService executor = Executors.newScheduledThreadPool(2); 
 final Future handler = executor.submit(new Callable(){ ... });
 executor.schedule(new Runnable(){
     public void run(){
         handler.cancel();
     }      
 }, 10000, TimeUnit.MILLISECONDS);

This will execute your handler (main functionality to be interrupted) for 10 seconds, then will cancel (i.e. interrupt) that specific task.

More Related Contents:

  1. How to wait for all threads to finish, using ExecutorService?
  2. Executors.newCachedThreadPool() versus Executors.newFixedThreadPool()
  3. What are the advantages of using an ExecutorService?
  4. Java’s Fork/Join vs ExecutorService – when to use which?
  5. Impossible to make a cached thread pool with a size limit?
  6. ThreadPoolExecutor Block When Queue Is Full?
  7. Java ExecutorService: awaitTermination of all recursively created tasks
  8. ThreadPoolExecutor Block When its Queue Is Full?
  9. How to pause/resume all threads in an ExecutorService in Java?
  10. ExecutorCompletionService? Why do need one if we have invokeAll?
  11. Why is creating a Thread said to be expensive?
  12. Why is i++ not atomic?
  13. Synchronization vs Lock
  14. How to properly shutdown java ExecutorService
  15. Prime numbers by Eratosthenes quicker sequential than concurrently?
  16. How to solve the “Double-Checked Locking is Broken” Declaration in Java?
  17. How to properly use Java Executor?
  18. What’s a monitor in Java?
  19. What is mutex and semaphore in Java ? What is the main difference?
  20. CountDownLatch vs. Semaphore
  21. Java threads and number of cores
  22. Parallel execution of directed acyclic graph of tasks
  23. Simplest and understandable example of volatile keyword in Java
  24. Programmatic deadlock detection in java
  25. Run Java Threads sequentially
  26. WAITING at sun.misc.Unsafe.park(Native Method)
  27. Java : Does wait() release lock from synchronized block
  28. How Threadpool re-use Threads and how it works
  29. What is the most frequent concurrency issue you’ve encountered in Java? [closed]
  30. Controlling Task execution order with ExecutorService

Leave a Comment