com.j_spaces.core.fifo

Class FifoBackgroundDispatcher

java.lang.Object

com.j_spaces.core.fifo.FifoBackgroundDispatcher

Direct Known Subclasses:

DefaultFifoBackgroundDispatcher

public abstract class FifoBackgroundDispatcher
extends Object

Since:

8.0.4

Author:

Niv Ingberg

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	_logger
protected FifoWorkerThread[]	_nonNotifyFifoThreads
protected FifoWorkerThread[]	_notifyFifoThreads

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FifoBackgroundDispatcher(int numNotifyFifoThreads, int numNonNotifyFifoThreads, CacheManager cacheManager, SpaceEngine engine)

Method Summary

Modifier and Type	Method and Description
abstract void	activateRequest(FifoBackgroundRequest rd)
protected static void	activateRequest(FifoBackgroundRequest rd, FifoWorkerThread[] workers)
abstract void	cancelRequest(FifoBackgroundRequest rd)
void	close()
protected abstract FifoWorkerThread	createFifoWorkerThread(int num, boolean isNotify, CacheManager cacheManager, SpaceEngine engine)
int	getNumNonNotifyFifoThreads()
int	getNumNotifyFifoThreads()
abstract void	positionAndActivateRequest(FifoBackgroundRequest rd)
protected static void	positionAndActivateRequest(FifoBackgroundRequest rd, FifoWorkerThread[] workers)
abstract void	positionRequest(FifoBackgroundRequest rd)
protected static void	positionRequest(FifoBackgroundRequest rd, FifoWorkerThread[] workers)

Methods inherited from class java.lang.Object

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

Field Detail

_logger

protected static final Logger _logger

_notifyFifoThreads

protected final FifoWorkerThread[] _notifyFifoThreads

_nonNotifyFifoThreads

protected final FifoWorkerThread[] _nonNotifyFifoThreads

Constructor Detail

FifoBackgroundDispatcher

protected FifoBackgroundDispatcher(int numNotifyFifoThreads,
                                   int numNonNotifyFifoThreads,
                                   CacheManager cacheManager,
                                   SpaceEngine engine)

Method Detail

createFifoWorkerThread

protected abstract FifoWorkerThread createFifoWorkerThread(int num,
                                                           boolean isNotify,
                                                           CacheManager cacheManager,
                                                           SpaceEngine engine)

close

public void close()

getNumNotifyFifoThreads

public int getNumNotifyFifoThreads()

getNumNonNotifyFifoThreads

public int getNumNonNotifyFifoThreads()

positionRequest

public abstract void positionRequest(FifoBackgroundRequest rd)

activateRequest

public abstract void activateRequest(FifoBackgroundRequest rd)

positionAndActivateRequest

public abstract void positionAndActivateRequest(FifoBackgroundRequest rd)

cancelRequest

public abstract void cancelRequest(FifoBackgroundRequest rd)

positionRequest

protected static void positionRequest(FifoBackgroundRequest rd,
                                      FifoWorkerThread[] workers)

activateRequest

protected static void activateRequest(FifoBackgroundRequest rd,
                                      FifoWorkerThread[] workers)

positionAndActivateRequest

protected static void positionAndActivateRequest(FifoBackgroundRequest rd,
                                                 FifoWorkerThread[] workers)