public final class BasicOperationScheduler extends Object
BasicOperationProcessor
. So
this class is purely responsible for assigning a 'task' to a particular thread.
The execute(Object, int, boolean)
accepts an Object instead of a runnable to prevent needing to
create wrapper runnables around tasks. This is done to reduce the amount of object litter and therefor
reduce pressure on the gc.Modifier and Type | Class and Description |
---|---|
class |
BasicOperationScheduler.PartitionThread |
Constructor and Description |
---|
BasicOperationScheduler(Node node,
ExecutionService executionService,
int operationThreadCount,
BasicOperationProcessor processor) |
Modifier and Type | Method and Description |
---|---|
void |
execute(Object task,
int partitionId,
boolean priority) |
int |
getOperationExecutorQueueSize() |
int |
getPriorityOperationExecutorQueueSize() |
void |
shutdown() |
public BasicOperationScheduler(Node node, ExecutionService executionService, int operationThreadCount, BasicOperationProcessor processor)
public int getOperationExecutorQueueSize()
public int getPriorityOperationExecutorQueueSize()
public void execute(Object task, int partitionId, boolean priority)
public void shutdown()
Copyright © 2014 Hazelcast, Inc.. All rights reserved.