ThreadQueueWorker<TItem, TWorker> Class

Worker processing queue in single (one per application and generic variant), ever-running asynchronous thread

Inheritance Hierarchy

System.Object
  CMS.Base.ThreadWorker<TWorker>
    CMS.Base.ThreadQueueWorker<TItem, TWorker>
      CMS.EventLog.EventLogWorker

Namespace: CMS.Base
Assembly: CMS.Base (in CMS.Base.dll) Version: 9.0.0

Syntax

public abstract class ThreadQueueWorker<TItem, TWorker> : ThreadWorker<TWorker>
where TItem : class
where TWorker : new(), ThreadQueueWorker<TItem, TWorker>

Type Parameters

TItem

TWorker

The ThreadQueueWorker<TItem, TWorker> type exposes the following members.

Constructors

	Name	Description
Protected method	ThreadQueueWorker<TItem, TWorker>

Fields

	Name	Description
Public field Static member	Events	Events fired by the worker

Properties

	Name	Description
Protected property	DefaultInterval	Gets the default interval in milliseconds for the worker. (Inherited from ThreadWorker<T>.)
Protected property	CheckDuplicity	If true, the queue checks the duplicity when inserting items. The duplicity is checked using the default comparer of the item.
Public property Static member	ItemsInQueue	Return the current number of items in the queue
Protected property	LastRun	Last run time (Inherited from ThreadWorker<T>.)
Protected property	MaintenanceInterval	Gets the maintenance interval in milliseconds for the worker. When 0 (default), the maintenance is not performed. (Inherited from ThreadWorker<T>.)
Protected property	NextMaintenance	Next maintenance time (Inherited from ThreadWorker<T>.)
Protected property	PollThread	Gets or sets thread which is periodically checking for new tasks. (Inherited from ThreadWorker<T>.)
Protected property	UseLogContext	If true, the thread uses a log context for its operations (Inherited from ThreadWorker<T>.)

Methods

	Name	Description
Protected method	AbortInternal	Aborts the worker and clears the queue (Overrides ThreadWorker<T>.AbortInternal().)
Public method Static member	ClearQueue	Clears the current queue
Protected method	CreateThread	Creates a worker thread object. Override to modify the thread configuration (Inherited from ThreadWorker<T>.)
Protected method	Dequeue	Returns the first item in the queue and removes it
Protected method	DoMaintenance	Runs the maintenance routine for the worker (Inherited from ThreadWorker<T>.)
Public method Static member	Enqueue	Adds new item to processing queue
Protected method	Finish	Finishes the worker process. Implement this method to specify what the worker must do in order to not lose its internal data when being finished. Leave empty if no extra action is required. (Inherited from ThreadWorker<T>.)
Protected method	Initialize	Initializes the worker. Runs in the worker thread before the thread processes the first iteration. (Inherited from ThreadWorker<T>.)
Protected method	Process	Method processing queues actions. (Overrides ThreadWorker<T>.Process().)
Protected method	ProcessItem	Processes the item in the queue. Override this method to process a single item from the queue.
Protected method	ProcessItems	Processes the given list of items. Override this method to process queued items as a bulk. Returns the number of processed items.
Protected method	RegisterInternal	Registers the worker (Inherited from ThreadWorker<T>.)
Protected method	ResetInternal	Obsolete. Resets the worker and clears the queue (Overrides ThreadWorker<T>.ResetInternal().)
Protected method	Run	Runs the action. (Inherited from ThreadWorker<T>.)
Protected method	RunAsync	Runs the task in an asynchronous thread. (Inherited from ThreadWorker<T>.)
Protected method	RunMaintenance	Runs the maintenance routine for the worker if it should run. (Inherited from ThreadWorker<T>.)
Protected method	RunProcess	Runs the internal process of the worker (Inherited from ThreadWorker<T>.)