com.j_spaces.core.fifo

Class FifoWorkerThread

java.lang.Object

java.lang.Thread

com.gigaspaces.internal.utils.concurrent.GSThread

com.j_spaces.core.fifo.FifoWorkerThread

All Implemented Interfaces:

Runnable

public abstract class FifoWorkerThread
extends GSThread

Since:

8.0.4

Author:

Niv Ingberg

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected CacheManager	_cacheManager
protected boolean	_closed
protected boolean	_closeThread
protected Context	_context
protected boolean	_isNotify
protected static org.slf4j.Logger	_logger
protected Object	_shutDown
protected int	_threadNum

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FifoWorkerThread(int num, boolean isNotify, String workerType, CacheManager cacheManager, SpaceEngine engine)

Method Summary

Modifier and Type	Method and Description
abstract void	activateFifoThread()
abstract void	close()
protected NotifyActionType	getNotifyType(int spaceOperation)
protected void	handleNonNotifyRequest(FifoBackgroundRequest rd)
protected abstract void	handleNotifyRequest(FifoBackgroundRequest rd)
protected void	handleNotifyRequest(FifoBackgroundRequest rd, NotifyActionType notifyType)
protected void	handleRequest(FifoBackgroundRequest rd)
protected void	performGeneralEntryNonNotify(IEntryHolder eh, FifoBackgroundRequest rd) perform general non-notify
protected void	performTemplateOnEntryNonNotify(IEntryHolder eh, ITemplateHolder template, FifoBackgroundRequest rd)
abstract void	positionAndActivateRequest(FifoBackgroundRequest rd)
abstract void	positionRequest(FifoBackgroundRequest rd)
protected void	processRejectedRequestsToPerform(FifoBackgroundRequest rd, List<FifoBackgroundRequest> rejectedRequestsToPerform)

Methods inherited from class com.gigaspaces.internal.utils.concurrent.GSThread

daemon

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, run, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

_logger

protected static final org.slf4j.Logger _logger

_threadNum

protected final int _threadNum

_isNotify

protected final boolean _isNotify

_cacheManager

protected final CacheManager _cacheManager

_shutDown

protected final Object _shutDown

_context

protected Context _context

_closed

protected boolean _closed

_closeThread

protected boolean _closeThread

Constructor Detail

FifoWorkerThread

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

Method Detail

close

public abstract void close()

positionRequest

public abstract void positionRequest(FifoBackgroundRequest rd)

activateFifoThread

public abstract void activateFifoThread()

positionAndActivateRequest

public abstract void positionAndActivateRequest(FifoBackgroundRequest rd)

getNotifyType

protected NotifyActionType getNotifyType(int spaceOperation)

handleRequest

protected void handleRequest(FifoBackgroundRequest rd)

handleNotifyRequest

protected abstract void handleNotifyRequest(FifoBackgroundRequest rd)
                                     throws SAException,
                                            EntryDeletedException

Throws:

SAException

EntryDeletedException

handleNotifyRequest

protected void handleNotifyRequest(FifoBackgroundRequest rd,
                                   NotifyActionType notifyType)
                            throws EntryDeletedException,
                                   SAException

Throws:

EntryDeletedException

SAException

performTemplateOnEntryNonNotify

protected void performTemplateOnEntryNonNotify(IEntryHolder eh,
                                               ITemplateHolder template,
                                               FifoBackgroundRequest rd)
                                        throws SAException,
                                               EntryDeletedException

Throws:

SAException

EntryDeletedException

performGeneralEntryNonNotify

protected void performGeneralEntryNonNotify(IEntryHolder eh,
                                            FifoBackgroundRequest rd)
                                     throws SAException,
                                            EntryDeletedException

perform general non-notify

Throws:

SAException

EntryDeletedException

processRejectedRequestsToPerform

protected void processRejectedRequestsToPerform(FifoBackgroundRequest rd,
                                                List<FifoBackgroundRequest> rejectedRequestsToPerform)
                                         throws SAException,
                                                EntryDeletedException

Throws:

SAException

EntryDeletedException

handleNonNotifyRequest

protected void handleNonNotifyRequest(FifoBackgroundRequest rd)
                               throws SAException,
                                      EntryDeletedException

Throws:

SAException

EntryDeletedException