io.zeebe.util.sched

Class WorkStealingGroup

java.lang.Object

io.zeebe.util.sched.WorkStealingGroup

public class WorkStealingGroup
extends Object

Workstealing group maintains a queue per thread.

Constructor Summary

Constructors

Constructor and Description
WorkStealingGroup(int numOfThreads)

Method Summary

Modifier and Type	Method and Description
protected ActorTask	getNextTask() Attempts to acquire the next task to execute
void	submit(ActorTask task, int threadId) Submit the task into the provided thread's queue

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkStealingGroup

public WorkStealingGroup(int numOfThreads)

Method Detail

submit

public void submit(ActorTask task,
                   int threadId)

Submit the task into the provided thread's queue

Parameters:

task - the task to submit

threadId - the id of the thread into which queue the task should be submitted

getNextTask

protected ActorTask getNextTask()

Attempts to acquire the next task to execute

Returns:

the acquired task or null if no task is available