io.zeebe.util.sched

Class ActorThreadGroup

java.lang.Object

io.zeebe.util.sched.ActorThreadGroup

Direct Known Subclasses:

CpuThreadGroup, IoThreadGroup

public abstract class ActorThreadGroup
extends Object

A thread group is a group of threads which process the same kind of tasks (ie. blocking I/O vs. CPU bound).

Field Summary

Fields

Modifier and Type	Field and Description
protected String	groupName
protected int	numOfThreads
protected MultiLevelWorkstealingGroup	tasks
protected ActorThread[]	threads

Constructor Summary

Constructors

Constructor and Description
ActorThreadGroup(String groupName, int numOfThreads, int numOfQueuesPerThread, ActorScheduler.ActorSchedulerBuilder builder)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	closeAsync()
protected abstract TaskScheduler	createTaskScheduler(MultiLevelWorkstealingGroup tasks, ActorScheduler.ActorSchedulerBuilder builder)
String	getGroupName()
protected abstract int	getLevel(ActorTask actorTask)
int	getNumOfThreads()
void	start()
void	submit(ActorTask actorTask)

Methods inherited from class java.lang.Object

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

Field Detail

groupName

protected final String groupName

numOfThreads

protected int numOfThreads

threads

protected final ActorThread[] threads

tasks

protected final MultiLevelWorkstealingGroup tasks

Constructor Detail

ActorThreadGroup

public ActorThreadGroup(String groupName,
                        int numOfThreads,
                        int numOfQueuesPerThread,
                        ActorScheduler.ActorSchedulerBuilder builder)

Method Detail

createTaskScheduler

protected abstract TaskScheduler createTaskScheduler(MultiLevelWorkstealingGroup tasks,
                                                     ActorScheduler.ActorSchedulerBuilder builder)

submit

public void submit(ActorTask actorTask)

getLevel

protected abstract int getLevel(ActorTask actorTask)

getGroupName

public String getGroupName()

getNumOfThreads

public int getNumOfThreads()

start

public void start()

closeAsync

public CompletableFuture<Void> closeAsync()