Package | Description |
---|---|
org.apache.storm.daemon.worker | |
org.apache.storm.executor | |
org.apache.storm.utils |
Modifier and Type | Method and Description |
---|---|
Utils.SmartThread |
WorkerTransfer.makeTransferThread() |
Utils.SmartThread |
WorkerState.makeTransferThread() |
Constructor and Description |
---|
ExecutorShutdown(Executor executor,
List<Utils.SmartThread> threads,
ArrayList<Task> taskDatas,
JCQueue recvQueue) |
Modifier and Type | Method and Description |
---|---|
static Utils.SmartThread |
Utils.asyncLoop(Callable afn)
Convenience method used when only the function is given.
|
static Utils.SmartThread |
Utils.asyncLoop(Callable afn,
boolean isDaemon,
Thread.UncaughtExceptionHandler eh,
int priority,
boolean isFactory,
boolean startImmediately,
String threadName)
Creates a thread that calls the given code repeatedly, sleeping for an interval of seconds equal to the return value of the previous call.
|
static Utils.SmartThread |
Utils.asyncLoop(Callable afn,
String threadName,
Thread.UncaughtExceptionHandler eh)
Convenience method used when only the function and name suffix are given.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.