com.hazelcast.durableexecutor.impl

Class DurableExecutorContainer

java.lang.Object

com.hazelcast.durableexecutor.impl.DurableExecutorContainer

public class DurableExecutorContainer
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	DurableExecutorContainer.TaskProcessor

Constructor Summary

Constructors

Constructor and Description
DurableExecutorContainer(NodeEngineImpl nodeEngine, String name, int partitionId, int durability, TaskRingBuffer ringBuffer)

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

DurableExecutorContainer

public DurableExecutorContainer(NodeEngineImpl nodeEngine,
                                String name,
                                int partitionId,
                                int durability,
                                TaskRingBuffer ringBuffer)

Method Detail

execute

public int execute(Callable callable)

putBackup

public void putBackup(int sequence,
                      Callable callable)

retrieveResult

public Object retrieveResult(int sequence)

disposeResult

public void disposeResult(int sequence)

retrieveAndDisposeResult

public Object retrieveAndDisposeResult(int sequence)

putResult

public void putResult(int sequence,
                      Object result)

shouldWait

public boolean shouldWait(int sequence)

getRingBuffer

public TaskRingBuffer getRingBuffer()

getDurability

public int getDurability()

getName

public String getName()