Package 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	Description
protected static final org.slf4j.Logger	_logger
protected final FifoWorkerThread[]	_nonNotifyFifoThreads
protected final FifoWorkerThread[]	_notifyFifoThreads

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

_logger

protected static final org.slf4j.Logger _logger

_notifyFifoThreads

protected final FifoWorkerThread[] _notifyFifoThreads

_nonNotifyFifoThreads

protected final FifoWorkerThread[] _nonNotifyFifoThreads

Constructor Details

FifoBackgroundDispatcher

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

Method Details

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)