Package org.apache.flink.util
Class ThrowableCatchingRunnable
- java.lang.Object
-
- org.apache.flink.util.ThrowableCatchingRunnable
-
- All Implemented Interfaces:
Runnable
public class ThrowableCatchingRunnable extends Object implements Runnable
This class catches all theThrowables
from the wrapped runnable. This class is useful when the wrapped runnable is submitted to an executor where the UncaughtExceptionHandler is not usable.
-
-
Constructor Summary
Constructors Constructor Description ThrowableCatchingRunnable(Consumer<Throwable> exceptionHandler, Runnable runnable)
-