private final class ProcedureExecutor.WorkerMonitor extends InlineChore
Modifier and Type | Field and Description |
---|---|
private float |
addWorkerStuckPercentage |
private static float |
DEFAULT_WORKER_ADD_STUCK_PERCENTAGE |
private static int |
DEFAULT_WORKER_MONITOR_INTERVAL |
private static int |
DEFAULT_WORKER_STUCK_THRESHOLD |
private int |
stuckThreshold |
private int |
timeoutInterval |
static String |
WORKER_ADD_STUCK_PERCENTAGE_CONF_KEY |
static String |
WORKER_MONITOR_INTERVAL_CONF_KEY |
static String |
WORKER_STUCK_THRESHOLD_CONF_KEY |
Constructor and Description |
---|
WorkerMonitor() |
Modifier and Type | Method and Description |
---|---|
private int |
checkForStuckWorkers() |
private void |
checkThreadCount(int stuckCount) |
int |
getTimeoutInterval() |
private void |
refreshConfig() |
void |
run() |
getTimeout, refreshTimeout
compareTo, getDelay, toString
public static final String WORKER_MONITOR_INTERVAL_CONF_KEY
private static final int DEFAULT_WORKER_MONITOR_INTERVAL
public static final String WORKER_STUCK_THRESHOLD_CONF_KEY
private static final int DEFAULT_WORKER_STUCK_THRESHOLD
public static final String WORKER_ADD_STUCK_PERCENTAGE_CONF_KEY
private static final float DEFAULT_WORKER_ADD_STUCK_PERCENTAGE
private float addWorkerStuckPercentage
private int timeoutInterval
private int stuckThreshold
public WorkerMonitor()
public void run()
private int checkForStuckWorkers()
private void checkThreadCount(int stuckCount)
private void refreshConfig()
public int getTimeoutInterval()
getTimeoutInterval
in class InlineChore
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.