akka.remote.artery

Class TaskRunner

java.lang.Object

akka.remote.artery.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 and 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 and Description
TaskRunner(ExtendedActorSystem system, int idleCpuLevel)

Method Summary

Modifier and Type	Method and 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()

Methods inherited from class java.lang.Object

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

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 interface java.lang.Runnable