Package org.apache.flink.util.concurrent

Class IgnoreShutdownRejectedExecutionHandler

java.lang.Object

org.apache.flink.util.concurrent.IgnoreShutdownRejectedExecutionHandler

All Implemented Interfaces:

RejectedExecutionHandler

public class IgnoreShutdownRejectedExecutionHandler
extends Object
implements RejectedExecutionHandler

Rejected executions are ignored or logged in debug if the executor is shutdown. Otherwise, RejectedExecutionException is thrown.

Constructor Summary

Constructors

Constructor	Description
IgnoreShutdownRejectedExecutionHandler()
IgnoreShutdownRejectedExecutionHandler(org.slf4j.Logger logger)

Method Summary

Modifier and Type	Method	Description
void	rejectedExecution(Runnable r, ThreadPoolExecutor executor)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IgnoreShutdownRejectedExecutionHandler

public IgnoreShutdownRejectedExecutionHandler()

IgnoreShutdownRejectedExecutionHandler

public IgnoreShutdownRejectedExecutionHandler(@Nullable
                                              org.slf4j.Logger logger)

Method Detail

rejectedExecution

public void rejectedExecution(Runnable r,
                              ThreadPoolExecutor executor)

Specified by:

rejectedExecution in interface RejectedExecutionHandler