How to timeout a thread

by

Indeed rather use ExecutorService instead of Timer, here’s an SSCCE:

package com.stackoverflow.q2275443;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

public class Test {
    public static void main(String[] args) throws Exception {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        Future<String> future = executor.submit(new Task());

        try {
            System.out.println("Started..");
            System.out.println(future.get(3, TimeUnit.SECONDS));
            System.out.println("Finished!");
        } catch (TimeoutException e) {
            future.cancel(true);
            System.out.println("Terminated!");
        }

        executor.shutdownNow();
    }
}

class Task implements Callable<String> {
    @Override
    public String call() throws Exception {
        Thread.sleep(4000); // Just to demo a long running task of 4 seconds.
        return "Ready!";
    }
}

Play a bit with the timeout argument in Future#get() method, e.g. increase it to 5 and you’ll see that the thread finishes. You can intercept the timeout in the catch (TimeoutException e) block.

Update: to clarify a conceptual misunderstanding, the sleep() is not required. It is just used for SSCCE/demonstration purposes. Just do your long running task right there in place of sleep(). Inside your long running task, you should be checking if the thread is not interrupted as follows:

while (!Thread.interrupted()) {
    // Do your long running task here.
}

More Related Contents:

  1. Pausing/stopping and starting/resuming Java TimerTask continuously?
  2. How could I add a simple delay in a Java Swing application?
  3. Android Timer schedule vs scheduleAtFixedRate
  4. Timer in Java Thread
  5. Running a Java Thread in intervals
  6. What does ‘synchronized’ mean?
  7. Synchronization vs Lock
  8. Prime numbers by Eratosthenes quicker sequential than concurrently?
  9. Java Synchronized Block for .class
  10. Synchronization of non-final field
  11. Executors.newCachedThreadPool() versus Executors.newFixedThreadPool()
  12. Most efficient way to log messages to JavaFX TextArea via threads with simple custom logging frameworks
  13. How to check if current thread is not main thread
  14. CompletableFuture is not getting executed. If I use the ExecutorService pool it works as expected but not with the common ForkJoinPool
  15. When does Java’s Thread.sleep throw InterruptedException?
  16. What is mutex and semaphore in Java ? What is the main difference?
  17. Parallel execution of directed acyclic graph of tasks
  18. Thread safety in Singleton
  19. Why single thread is faster than multithreading in Java?
  20. Run Java Threads sequentially
  21. How do I set the timeout for a JAX-WS webservice client?
  22. Java : Does wait() release lock from synchronized block
  23. How Threadpool re-use Threads and how it works
  24. Is Cipher thread-safe?
  25. Write end dead exception using PipedInputStream java
  26. What makes the execution order of threads unpredictable?
  27. Why is Thread.stop() so dangerous
  28. Updating your UI and forcibly waiting before continuing JavaFX
  29. How to test methods that call System.exit()?
  30. Java Swing Timer

Leave a Comment