Unhandled exceptions with Java scheduled executors Unhandled exceptions with Java scheduled executors multithreading multithreading

Unhandled exceptions with Java scheduled executors


The Javadoc of both scheduleAtFixedRate and scheduleWithFixedDelay says "If any execution of the task encounters an exception, subsequent executions are suppressed." I don't find that to be exactly crystal clear, but it seems to be saying that if your run method throws any kind of exception, then the scheduler will effectively drop that task. Any other tasks running via that scheduler should not be affected. It shouldn't be hard to test what it actually does...

Cancellation of the task may not necessarily be a bad thing. If the run method throws a RuntimeException, it's probably got a bug somewhere, and the state of the system is unknown. But at minimum I would advise catching RuntimeException in your run method, and logging the full stack trace at SEVERE. You may want to then rethrow to cancel the task, depending on the circumstances. But either way you'll need the logging to have a fighting chance of working out what went wrong.


If you are using scheduleAtFixedRate() or scheduleAtFixedDelay(), and your task bails out with an exception, that task will not be rescheduled. However, other independent tasks should continue to execute as expected. (See API Docs). If you care that this has happened, you can grab ahold of the ScheduledFuture that is returned and call the get() method. If the underlying task tosses an exception, you'll get it thrown out of the get() method, wrapped in an ExecutionException.


This man had the same problem.

http://code.nomad-labs.com/2011/12/09/mother-fk-the-scheduledexecutorservice/

His solution is to catch Exception inside the runnable and re throw an RuntimeException:

try {       theRunnable.run();    } catch (Exception e) {       // LOG IT HERE!!!       System.err.println("error in executing: " + theRunnable + ". It will no longer be run!");       e.printStackTrace();       // and re throw it so that the Executor also gets this error so that it can do what it would       // usually do       throw new RuntimeException(e);}