com.hazelcast.durableexecutor.impl

Class TaskRingBuffer

java.lang.Object

com.hazelcast.durableexecutor.impl.TaskRingBuffer

public class TaskRingBuffer
extends Object

A RingBuffer implementation to store tasks and results of those task Only a single thread (partition-operation-thread) accesses the instance

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	TaskRingBuffer.DurableIterator

Constructor Summary

Constructors

Constructor and Description
TaskRingBuffer()
TaskRingBuffer(int capacity)

Method Summary

Methods

Modifier and Type	Method and Description
int	add(Callable task) Adds the task to next available spot and returns the sequence corresponding to that spot.
void	dispose(int sequence) Disposes the sequence
TaskRingBuffer.DurableIterator	iterator()
void	read(ObjectDataInput in)
void	remove(int sequence) Removes the task with the given sequence
Object	retrieve(int sequence) Gets the response
void	write(ObjectDataOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskRingBuffer

public TaskRingBuffer()

TaskRingBuffer

public TaskRingBuffer(int capacity)

Method Detail

add

public int add(Callable task)

Adds the task to next available spot and returns the sequence corresponding to that spot. throws exception if there is no available spot

Parameters:

task - The task

Returns:

the sequence

Throws:

RejectedExecutionException - if there is not available spot for the task

remove

public void remove(int sequence)

Removes the task with the given sequence

Parameters:

sequence - the sequence

dispose

public void dispose(int sequence)

Disposes the sequence

Parameters:

sequence - The sequence

retrieve

public Object retrieve(int sequence)

Gets the response

Parameters:

sequence - The sequence

Returns:

The response

write

public void write(ObjectDataOutput out)
           throws IOException

Throws:

IOException

read

public void read(ObjectDataInput in)
          throws IOException

Throws:

IOException

iterator

public TaskRingBuffer.DurableIterator iterator()