io.zeebe.util.sched

Class CpuThreadGroup

java.lang.Object

io.zeebe.util.sched.ActorThreadGroup

io.zeebe.util.sched.CpuThreadGroup

public class CpuThreadGroup
extends ActorThreadGroup

Thread group for the non-blocking, CPU bound, tasks.

Field Summary

Fields inherited from class io.zeebe.util.sched.ActorThreadGroup

groupName, numOfThreads, tasks, threads

Constructor Summary

Constructors

Constructor and Description
CpuThreadGroup(ActorScheduler.ActorSchedulerBuilder builder)

Method Summary

Modifier and Type	Method and Description
protected TaskScheduler	createTaskScheduler(MultiLevelWorkstealingGroup tasks, ActorScheduler.ActorSchedulerBuilder builder)
protected int	getLevel(ActorTask actorTask)

Methods inherited from class io.zeebe.util.sched.ActorThreadGroup

closeAsync, getGroupName, getNumOfThreads, start, submit

Methods inherited from class java.lang.Object

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

Constructor Detail

CpuThreadGroup

public CpuThreadGroup(ActorScheduler.ActorSchedulerBuilder builder)

Method Detail

createTaskScheduler

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

Specified by:

createTaskScheduler in class ActorThreadGroup

getLevel

protected int getLevel(ActorTask actorTask)

Specified by:

getLevel in class ActorThreadGroup