OGRE  13.6
Object-Oriented Graphics Rendering Engine
Ogre::WorkQueue Class Referenceabstract

Interface to a general purpose request / response style background work queue. More...

#include <OgreWorkQueue.h>

+ Inheritance diagram for Ogre::WorkQueue:

Classes

class  Request
 General purpose request structure. More...
 
class  RequestHandler
 Interface definition for a handler of requests. More...
 
struct  Response
 General purpose response structure. More...
 
class  ResponseHandler
 Interface definition for a handler of responses. More...
 

Public Types

typedef unsigned long long int RequestID
 Numeric identifier for a request. More...
 

Public Member Functions

 WorkQueue ()
 
virtual ~WorkQueue ()
 
virtual void abortAllRequests ()=0
 Abort all previously issued requests. More...
 
virtual bool abortPendingRequest (RequestID id)=0
 Abort request if it is not being processed currently. More...
 
virtual void abortPendingRequestsByChannel (uint16 channel)=0
 Abort all previously issued requests in a given channel. More...
 
virtual void abortRequest (RequestID id)=0
 Abort a previously issued request. More...
 
virtual void abortRequestsByChannel (uint16 channel)=0
 Abort all previously issued requests in a given channel. More...
 
virtual RequestID addRequest (uint16 channel, uint16 requestType, const Any &rData, uint8 retryCount=0, bool forceSynchronous=false, bool idleThread=false)=0
 Add a new request to the queue. More...
 
virtual void addRequestHandler (uint16 channel, RequestHandler *rh)=0
 Add a request handler instance to the queue. More...
 
virtual void addResponseHandler (uint16 channel, ResponseHandler *rh)=0
 Add a response handler instance to the queue. More...
 
virtual uint16 getChannel (const String &channelName)
 Get a channel ID for a given channel name. More...
 
virtual bool getRequestsAccepted () const =0
 Returns whether requests are being accepted right now. More...
 
virtual unsigned long getResponseProcessingTimeLimit () const =0
 Get the time limit imposed on the processing of responses in a single frame, in milliseconds (0 indicates no limit). More...
 
virtual bool isPaused () const =0
 Return whether the queue is paused ie not sending more work to workers. More...
 
virtual void processResponses ()=0
 Process the responses in the queue. More...
 
virtual void removeRequestHandler (uint16 channel, RequestHandler *rh)=0
 Remove a request handler. More...
 
virtual void removeResponseHandler (uint16 channel, ResponseHandler *rh)=0
 Remove a Response handler. More...
 
virtual void setPaused (bool pause)=0
 Set whether to pause further processing of any requests. More...
 
virtual void setRequestsAccepted (bool accept)=0
 Set whether to accept new requests or not. More...
 
virtual void setResponseProcessingTimeLimit (unsigned long ms)=0
 Set the time limit imposed on the processing of responses in a single frame, in milliseconds (0 indicates no limit). More...
 
virtual void shutdown ()=0
 Shut down the queue. More...
 
virtual void startup (bool forceRestart=true)=0
 Start up the queue with the options that have been set. More...
 

Detailed Description

Interface to a general purpose request / response style background work queue.

Remarks
A work queue is a simple structure, where requests for work are placed onto the queue, then removed by a worker for processing, then finally a response is placed on the result queue for the originator to pick up at their leisure. The typical use for this is in a threaded environment, although any kind of deferred processing could use this approach to decouple and distribute work over a period of time even if it was single threaded.
WorkQueues also incorporate thread pools. One or more background worker threads can wait on the queue and be notified when a request is waiting to be processed. For maximal thread usage, a WorkQueue instance should be shared among many sources of work, rather than many work queues being created. This way, you can share a small number of hardware threads among a large number of background tasks. This doesn't mean you have to implement all the request processing in one class, you can plug in many handlers in order to process the requests.
This is an abstract interface definition; users can subclass this and provide their own implementation if required to centralise task management in their own subsystems. We also provide a default implementation in the form of DefaultWorkQueue.

Member Typedef Documentation

◆ RequestID

typedef unsigned long long int Ogre::WorkQueue::RequestID

Numeric identifier for a request.

Constructor & Destructor Documentation

◆ WorkQueue()

Ogre::WorkQueue::WorkQueue ( )
inline

◆ ~WorkQueue()

virtual Ogre::WorkQueue::~WorkQueue ( )
inlinevirtual

Member Function Documentation

◆ startup()

virtual void Ogre::WorkQueue::startup ( bool  forceRestart = true)
pure virtual

Start up the queue with the options that have been set.

Parameters
forceRestartIf the queue is already running, whether to shut it down and restart.

◆ addRequestHandler()

virtual void Ogre::WorkQueue::addRequestHandler ( uint16  channel,
RequestHandler rh 
)
pure virtual

Add a request handler instance to the queue.

Remarks
Every queue must have at least one request handler instance for each channel in which requests are raised. If you add more than one handler per channel, then you must implement canHandleRequest differently in each if you wish them to respond to different requests.
Parameters
channelThe channel for requests you want to handle
rhYour handler

Implemented in Ogre::DefaultWorkQueueBase.

◆ removeRequestHandler()

virtual void Ogre::WorkQueue::removeRequestHandler ( uint16  channel,
RequestHandler rh 
)
pure virtual

Remove a request handler.

Implemented in Ogre::DefaultWorkQueueBase.

◆ addResponseHandler()

virtual void Ogre::WorkQueue::addResponseHandler ( uint16  channel,
ResponseHandler rh 
)
pure virtual

Add a response handler instance to the queue.

Remarks
Every queue must have at least one response handler instance for each channel in which requests are raised. If you add more than one, then you must implement canHandleResponse differently in each if you wish them to respond to different responses.
Parameters
channelThe channel for responses you want to handle
rhYour handler

Implemented in Ogre::DefaultWorkQueueBase.

◆ removeResponseHandler()

virtual void Ogre::WorkQueue::removeResponseHandler ( uint16  channel,
ResponseHandler rh 
)
pure virtual

Remove a Response handler.

Implemented in Ogre::DefaultWorkQueueBase.

◆ addRequest()

virtual RequestID Ogre::WorkQueue::addRequest ( uint16  channel,
uint16  requestType,
const Any rData,
uint8  retryCount = 0,
bool  forceSynchronous = false,
bool  idleThread = false 
)
pure virtual

Add a new request to the queue.

Parameters
channelThe channel this request will go into = 0; the channel is the top-level categorisation of the request
requestTypeAn identifier that's unique within this channel which identifies the type of the request (user decides the actual value)
rDataThe data required by the request process.
retryCountThe number of times the request should be retried if it fails.
forceSynchronousForces the request to be processed immediately even if threading is enabled.
idleThreadRequest should be processed on the idle thread. Idle requests will be processed on a single worker thread. You should use this in the following situations:
  1. If a request handler can't process multiple requests in parallel.
  2. If you add lot of requests, but you want to keep the game fast.
  3. If you have lot of more important threads. (example: physics).
Returns
The ID of the request that has been added

Implemented in Ogre::DefaultWorkQueueBase.

◆ abortRequest()

virtual void Ogre::WorkQueue::abortRequest ( RequestID  id)
pure virtual

Abort a previously issued request.

If the request is still waiting to be processed, it will be removed from the queue.

Parameters
idThe ID of the previously issued request.

Implemented in Ogre::DefaultWorkQueueBase.

◆ abortPendingRequest()

virtual bool Ogre::WorkQueue::abortPendingRequest ( RequestID  id)
pure virtual

Abort request if it is not being processed currently.

Parameters
idThe ID of the previously issued request.
Return values
trueIf request was aborted successfully.
falseIf request is already being processed so it can not be aborted.

Implemented in Ogre::DefaultWorkQueueBase.

◆ abortRequestsByChannel()

virtual void Ogre::WorkQueue::abortRequestsByChannel ( uint16  channel)
pure virtual

Abort all previously issued requests in a given channel.

Any requests still waiting to be processed of the given channel, will be removed from the queue. Requests which are processed, but response handler is not called will also be removed.

Parameters
channelThe type of request to be aborted

Implemented in Ogre::DefaultWorkQueueBase.

◆ abortPendingRequestsByChannel()

virtual void Ogre::WorkQueue::abortPendingRequestsByChannel ( uint16  channel)
pure virtual

Abort all previously issued requests in a given channel.

Any requests still waiting to be processed of the given channel, will be removed from the queue. It will not remove requests, where the request handler is already called.

Parameters
channelThe type of request to be aborted

Implemented in Ogre::DefaultWorkQueueBase.

◆ abortAllRequests()

virtual void Ogre::WorkQueue::abortAllRequests ( )
pure virtual

Abort all previously issued requests.

Any requests still waiting to be processed will be removed from the queue. Any requests that are being processed will still complete.

Implemented in Ogre::DefaultWorkQueueBase.

◆ setPaused()

virtual void Ogre::WorkQueue::setPaused ( bool  pause)
pure virtual

Set whether to pause further processing of any requests.

If true, any further requests will simply be queued and not processed until setPaused(false) is called. Any requests which are in the process of being worked on already will still continue.

Implemented in Ogre::DefaultWorkQueueBase.

◆ isPaused()

virtual bool Ogre::WorkQueue::isPaused ( ) const
pure virtual

Return whether the queue is paused ie not sending more work to workers.

Implemented in Ogre::DefaultWorkQueueBase.

◆ setRequestsAccepted()

virtual void Ogre::WorkQueue::setRequestsAccepted ( bool  accept)
pure virtual

Set whether to accept new requests or not.

If true, requests are added to the queue as usual. If false, requests are silently ignored until setRequestsAccepted(true) is called.

Implemented in Ogre::DefaultWorkQueueBase.

◆ getRequestsAccepted()

virtual bool Ogre::WorkQueue::getRequestsAccepted ( ) const
pure virtual

Returns whether requests are being accepted right now.

Implemented in Ogre::DefaultWorkQueueBase.

◆ processResponses()

virtual void Ogre::WorkQueue::processResponses ( )
pure virtual

Process the responses in the queue.

Remarks
This method is public, and must be called from the main render thread to 'pump' responses through the system. The method will usually try to clear all responses before returning = 0; however, you can specify a time limit on the response processing to limit the impact of spikes in demand by calling setResponseProcessingTimeLimit.

Implemented in Ogre::DefaultWorkQueueBase.

◆ getResponseProcessingTimeLimit()

virtual unsigned long Ogre::WorkQueue::getResponseProcessingTimeLimit ( ) const
pure virtual

Get the time limit imposed on the processing of responses in a single frame, in milliseconds (0 indicates no limit).

Implemented in Ogre::DefaultWorkQueueBase.

◆ setResponseProcessingTimeLimit()

virtual void Ogre::WorkQueue::setResponseProcessingTimeLimit ( unsigned long  ms)
pure virtual

Set the time limit imposed on the processing of responses in a single frame, in milliseconds (0 indicates no limit).

This sets the maximum time that will be spent in processResponses() in a single frame. The default is 10ms.

Implemented in Ogre::DefaultWorkQueueBase.

◆ shutdown()

virtual void Ogre::WorkQueue::shutdown ( )
pure virtual

Shut down the queue.

◆ getChannel()

virtual uint16 Ogre::WorkQueue::getChannel ( const String channelName)
virtual

Get a channel ID for a given channel name.

Remarks
Channels are assigned on a first-come, first-served basis and are not persistent across application instances. This method allows applications to not worry about channel clashes through manually assigned channel numbers.

The documentation for this class was generated from the following file: