How do I call some blocking method with a timeout in Java?

by

You could use an Executor:

ExecutorService executor = Executors.newCachedThreadPool();
Callable<Object> task = new Callable<Object>() {
   public Object call() {
      return something.blockingMethod();
   }
};
Future<Object> future = executor.submit(task);
try {
   Object result = future.get(5, TimeUnit.SECONDS); 
} catch (TimeoutException ex) {
   // handle the timeout
} catch (InterruptedException e) {
   // handle the interrupts
} catch (ExecutionException e) {
   // handle other exceptions
} finally {
   future.cancel(true); // may or may not desire this
}

If the future.get doesn’t return in 5 seconds, it throws a TimeoutException. The timeout can be configured in seconds, minutes, milliseconds or any unit available as a constant in TimeUnit.

See the JavaDoc for more detail.

More Related Contents:

  1. Custom thread pool in Java 8 parallel stream
  2. Random errors when changing series using JFreeChart
  3. How to wait for all threads to finish, using ExecutorService?
  4. Is there an advantage to use a Synchronized Method instead of a Synchronized Block?
  5. Update JLabel every X seconds from ArrayList – Java
  6. What’s the difference between ConcurrentHashMap and Collections.synchronizedMap(Map)?
  7. When and how should I use a ThreadLocal variable?
  8. What is the difference between Thread.start() and Thread.run()?
  9. Practical uses for AtomicInteger
  10. Is there an ExecutorService that uses the current thread?
  11. Why use a ReentrantLock if one can use synchronized(this)?
  12. Is volatile expensive?
  13. Choosing the best concurrency list in Java [closed]
  14. Java swing GUI freezes
  15. Different types of thread-safe Sets in Java
  16. Constructor synchronization in Java
  17. How can CopyOnWriteArrayList be thread-safe?
  18. Instruction reordering & happens-before relationship [duplicate]
  19. Memory barriers and coding style over a Java VM
  20. Java socket swingWorker running but no message received or transmitted
  21. When should we use Java’s Thread over Executor?
  22. Uninitialized object leaked to another thread despite no code explicitly leaking it?
  23. How LongAdder performs better than AtomicLong
  24. Whether to use invokeAll or submit – java Executor service
  25. LinkedBlockingQueue vs ConcurrentLinkedQueue
  26. How to reduce java concurrent mode failure and excessive gc
  27. Does a breakpoint halt all threads?
  28. What is optimum thread pool size for simple program running cpu based tasks in Java
  29. How to combine 3 or more CompletionStages?
  30. When is it preferable to use volatile boolean in Java rather than AtomicBoolean? [duplicate]

Leave a Comment