public class DurableExecutorContainer extends Object
Modifier and Type | Class and Description |
---|---|
class |
DurableExecutorContainer.TaskProcessor |
Constructor and Description |
---|
DurableExecutorContainer(NodeEngineImpl nodeEngine,
String name,
int partitionId,
int durability,
TaskRingBuffer ringBuffer) |
Modifier and Type | Method and Description |
---|---|
void |
disposeResult(int sequence) |
int |
execute(Callable callable) |
int |
getDurability() |
String |
getName() |
TaskRingBuffer |
getRingBuffer() |
void |
putBackup(int sequence,
Callable callable) |
void |
putResult(int sequence,
Object result) |
Object |
retrieveAndDisposeResult(int sequence) |
Object |
retrieveResult(int sequence) |
boolean |
shouldWait(int sequence) |
public DurableExecutorContainer(NodeEngineImpl nodeEngine, String name, int partitionId, int durability, TaskRingBuffer ringBuffer)
public int execute(Callable callable)
public void putBackup(int sequence, Callable callable)
public Object retrieveResult(int sequence)
public void disposeResult(int sequence)
public Object retrieveAndDisposeResult(int sequence)
public void putResult(int sequence, Object result)
public boolean shouldWait(int sequence)
public TaskRingBuffer getRingBuffer()
public int getDurability()
public String getName()
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.