|
|
@ -21,7 +21,6 @@ import cn.hippo4j.core.config.ApplicationContextHolder;
|
|
|
|
import cn.hippo4j.core.executor.ExtensibleThreadPoolExecutor;
|
|
|
|
import cn.hippo4j.core.executor.ExtensibleThreadPoolExecutor;
|
|
|
|
import cn.hippo4j.core.executor.plugin.RejectedAwarePlugin;
|
|
|
|
import cn.hippo4j.core.executor.plugin.RejectedAwarePlugin;
|
|
|
|
import cn.hippo4j.threadpool.alarm.api.ThreadPoolCheckAlarm;
|
|
|
|
import cn.hippo4j.threadpool.alarm.api.ThreadPoolCheckAlarm;
|
|
|
|
import lombok.NonNull;
|
|
|
|
|
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
|
|
|
|
|
|
|
|
|
import java.util.Optional;
|
|
|
|
import java.util.Optional;
|
|
|
@ -38,7 +37,6 @@ public class TaskRejectNotifyAlarmPlugin implements RejectedAwarePlugin {
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Thread pool check alarm
|
|
|
|
* Thread pool check alarm
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
@NonNull
|
|
|
|
|
|
|
|
private final ThreadPoolCheckAlarm threadPoolCheckAlarm;
|
|
|
|
private final ThreadPoolCheckAlarm threadPoolCheckAlarm;
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|