WorkerThreadPool Class

Standard constructor, initializes a threadpool without support for COM.

Creates a new WorkerThreadPool instance.

Creates a new WorkerThreadPool instance.

Get a lazy initialized singleton instance of WorkerThreadPool (thread-safe). Per default the Threadpool is prepared for usage with COM, see InstanceInitializesCOM.

Whether the threadpool returned by Instance initializes to let the threads in the pool make use of COM objects. The default value is true.

Whether the threadpool returned by Instance uses LIFO, the default value is false

The maximum time a thread may be busy until it is aborted.

The maximum cpu usage in percent were spawning additional worker threads is allowed

The maximum time a thread may be idle until it is removed from the pool if more that MinWorkerThreads are available

Gets or sets the maximum time threads are given to finish when the ThreadPool is terminated before they are aborted.

The maximum number of worker threads the pool may allocate

The minimum number of worker threads

If this property is set to true the processing of new work items is paused, if it is set to false, processing is resumed. Getter and setter of this method are thread safe.

If this property is set to true, the threadpool queries the current overall cpu load to determine whether to start additional threads that process the work items. . The default value for this setting is true.

Returns the number of work items residing in the queue waiting to get processed by the next free thread.

Returns true if processing was terminated via TerminateProcessing or TerminateProcessing(Boolean). Is reset to false in a call to StartProcessing.

If set to False, the oldest work item in the queue will be used a next item. This is the default value. If set to True, the newest work item in the queue will be used as next work item. True can be a good setting if the number of work items is large and their order doesn't matter

Returns the number of current work items.

This method removes threads from the busy pool if the maximum busy time is exceeded. Additionally if the thread is being stopped, if it doesn't join within 100ms abort is signalled via Abort.

Adds a work item to the internal queue but and immediately starts processing the item, see also AddWorkItem(IWorkItem, Boolean) and StartProcessing.

Adds a work item to the internal queue but does not yet start processing them, see StartProcessing for that.

Determines whether new threads should be spawned, ensures that MinWorkerThreads threads are available for processing

Call this method to check if the thread pool is still available.

Call this method to clean up all threads from the pool, in that case the ThreadPool instance cannot be used anymore, calls to functions of it will result in an ObjectDisposedException.

Implementation of IDispsable interface

Determines the overall cpu usage of the current process

Stops any pending threads if the applications exits

Adds a work item to the Threadpool that is immediately being processed. When the WorkItem is finished Event OnCompleted is raised on the calling synchronization context, so that no BeginInvoke is needed to update the main thread.

Adds a user work item to the Threadpool that is immediately being processed.

Adds a user work item to the Threadpool that is immediately being processed.

Adds a user work item to the Threadpool that is immediately being processed and tagged with the given handle.

Adds a user work item to the Threadpool that is processed after the given time and tagged with the given handle.

Adds an ActionT delegate call to the work item queue.

Adds an ActionT delegate call to the work item queue.

Adds an ActionT delegate call to the work item queue.

This method removes threads from the idle pool where the maximum idle time is exceeded. This method does nothing if only MinWorkerThreads are active

Start processing the work items (AddWorkItem(IWorkItem, Boolean))

Stops processing work items that are queued. Running threads will be aborted after MaxTimeUntilHardTerminate ms.

Stops processing work items that are queued.

Stops processing the threads.

Removes all pending work items from the work queue and terminates the running work items having the tag specified.

Removes all pending work items of type 'type'.

Returns a string that represents the current object.

Returns the list of WorkItems in the Queue and that are being processed at the moment. Note that the NameTag has to be set when queueing the items with QueueUserWorkItem.

Waits until all threads finished processing (the workitem queue is empty).

Waits until all threads finished processing (the workitem queue is empty).

This event occurs if the threads finished processing all workitems, it happens from a different thread context. So do not perform gui operations directly.

This event occurs if a new work item begins to process