Package akka.remote.artery.aeron
Class TaskRunner
- java.lang.Object
-
- akka.remote.artery.aeron.TaskRunner
-
- All Implemented Interfaces:
java.lang.Runnable
public class TaskRunner extends java.lang.Object implements java.lang.Runnable
INTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
TaskRunner.Add
static class
TaskRunner.Add$
static interface
TaskRunner.Command
static class
TaskRunner.CommandQueue
static class
TaskRunner.Remove
static class
TaskRunner.Remove$
static class
TaskRunner.Shutdown$
-
Constructor Summary
Constructors Constructor Description TaskRunner(ExtendedActorSystem system, int idleCpuLevel)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
command(TaskRunner.Command cmd)
static org.agrona.concurrent.IdleStrategy
createIdleStrategy(int idleCpuLevel)
int
idleCpuLevel()
void
run()
void
start()
scala.concurrent.Future<Done>
stop()
-
-
-
Constructor Detail
-
TaskRunner
public TaskRunner(ExtendedActorSystem system, int idleCpuLevel)
-
-
Method Detail
-
createIdleStrategy
public static org.agrona.concurrent.IdleStrategy createIdleStrategy(int idleCpuLevel)
-
idleCpuLevel
public int idleCpuLevel()
-
start
public void start()
-
stop
public scala.concurrent.Future<Done> stop()
-
command
public void command(TaskRunner.Command cmd)
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
-