Package com.gigaspaces.datasource.concurrentaccess

Class SharedDataIteratorSource<T>

java.lang.Object

com.gigaspaces.datasource.concurrentaccess.SharedDataIteratorSource<T>

public class SharedDataIteratorSource<T>
extends Object

Used to create SharedDataIterator over a single DataIterator, the iterator source is in charge of mediating between the shared iterators, always only one shared iterator is accessing the actual iterator

Since:

7.0

Author:

eitany

Constructor Summary

Constructors

Constructor	Description
SharedDataIteratorSource(Object identifier, ISourceDataIteratorProvider<T> sourceDataIteratorProvider, long timeToLive)	Construct a new source

Method Summary

Modifier and Type	Method	Description
void	addStateChangedListener(ISharedDataIteratorSourceStateChangedListener<T> listener)	Subscribe to state changed events
void	closeSharedIterator()	Signal the source this shared data iterator is closed
DataIterator<T>	getIterator()	Gets a new shared data iterator over the source data iterator
T	getNext(int index)	Called by the shared iterators to get their next object according to the specified index

Methods inherited from class java.lang.Object

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

Constructor Details

SharedDataIteratorSource

public SharedDataIteratorSource(Object identifier,
 ISourceDataIteratorProvider<T> sourceDataIteratorProvider,
 long timeToLive)

Construct a new source

Parameters:

sourceDataIterator - data iterator to wrap

timeToLive - time in miliseconds that once elapsed this iterator source is considered expired and will no longer receive requests for new iterators

Method Details

getIterator

public DataIterator<T> getIterator()
                            throws SharedDataIteratorSourceClosedException,
SharedDataIteratorSourceExpiredException,
DataSourceException

Gets a new shared data iterator over the source data iterator

Throws:

SharedDataIteratorSourceClosedException

SharedDataIteratorSourceExpiredException

DataSourceException

closeSharedIterator

public void closeSharedIterator()

Signal the source this shared data iterator is closed

getNext

public T getNext(int index)

Called by the shared iterators to get their next object according to the specified index

Parameters:

index - specified index

addStateChangedListener

public void addStateChangedListener(ISharedDataIteratorSourceStateChangedListener<T> listener)

Subscribe to state changed events