Package com.j_spaces.core.fifo

Class DefaultFifoBackgroundDispatcher

java.lang.Object

com.j_spaces.core.fifo.FifoBackgroundDispatcher

com.j_spaces.core.fifo.DefaultFifoBackgroundDispatcher

public class DefaultFifoBackgroundDispatcher
extends FifoBackgroundDispatcher

position fifo requests for notify and non-notify templates background search and consume

Since:

7.1

Version:

1.0

Author:

Yechiel Fefer

Field Summary

Fields

Modifier and Type	Field	Description
static final long	NON_FIFO_EVENTS_MAX_WAIT_TIME

Fields inherited from class com.j_spaces.core.fifo.FifoBackgroundDispatcher

_logger, _nonNotifyFifoThreads, _notifyFifoThreads

Constructor Summary

Constructors

Constructor	Description
DefaultFifoBackgroundDispatcher(int numNotifyFifoThreads, int numNonNotifyFifoThreads, CacheManager cacheManager, SpaceEngine engine)

Method Summary

Modifier and Type	Method	Description
void	activateRequest(FifoBackgroundRequest rd)
void	cancelRequest(FifoBackgroundRequest rd)
protected FifoWorkerThread	createFifoWorkerThread(int num, boolean isNotify, CacheManager cacheManager, SpaceEngine engine)
void	positionAndActivateRequest(FifoBackgroundRequest rd)
void	positionRequest(FifoBackgroundRequest rd)

Methods inherited from class com.j_spaces.core.fifo.FifoBackgroundDispatcher

activateRequest, close, getNumNonNotifyFifoThreads, getNumNotifyFifoThreads, positionAndActivateRequest, positionRequest

Methods inherited from class java.lang.Object

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

Field Details

NON_FIFO_EVENTS_MAX_WAIT_TIME

public static final long NON_FIFO_EVENTS_MAX_WAIT_TIME

See Also:

• Constant Field Values

Constructor Details

DefaultFifoBackgroundDispatcher

public DefaultFifoBackgroundDispatcher(int numNotifyFifoThreads,
 int numNonNotifyFifoThreads,
 CacheManager cacheManager,
 SpaceEngine engine)

Method Details

createFifoWorkerThread

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

Specified by:

createFifoWorkerThread in class FifoBackgroundDispatcher

positionRequest

public void positionRequest(FifoBackgroundRequest rd)

Specified by:

positionRequest in class FifoBackgroundDispatcher

activateRequest

public void activateRequest(FifoBackgroundRequest rd)

Specified by:

activateRequest in class FifoBackgroundDispatcher

positionAndActivateRequest

public void positionAndActivateRequest(FifoBackgroundRequest rd)

Specified by:

positionAndActivateRequest in class FifoBackgroundDispatcher

cancelRequest

public void cancelRequest(FifoBackgroundRequest rd)

Specified by:

cancelRequest in class FifoBackgroundDispatcher