IThreadPoolService
Last updated
Last updated
IThreadPoolService
in assembly SanteDB.Core.Api version 3.0.1980.0
Represents a thread pooling service
Operation | Response/Return | Input/Parameter | Description |
---|---|---|---|
Represents a thread pool which is implemented separately from the default .net threadpool, this is to reduce the load on the .net framework thread pool
Many SanteDB jobs use threads to perform background tasks such as refreshes, matching, job execution, etc. Because we don't want uncontrolled explosion of threads, we use a thread pool in order to control the number of active threads which are being used.
The default .NET thread pool can bounce work between threads when the thread enters a wait state, this can cause issues with the REDIS connection multiplexer
SanteDB plugins may use PLINQ or other TPL libraries which require using .NET thread pool - and we don't want longer running processess consuming those threads
Implementers may wish to have more control over how the Thread pool uses resources
This thread pool works by spinning up a pool of threads which wait for Object})) which initiates (or queues) a request to perform background work. When an available thread in the pool can execute the task, the task will be run and the thread will work on the next work item.
If the thread pool needs additional threads (i.e. there are a lot of items in the backlog) it will spin up new reserved threads at a rate of number of CPUs on the machine. This continues until the environment variable SDB_MAX_THREADS_PER_CPU is hit.
Conversely, if the thread pool threads remain idle for too long (1 minute) they are destroyed and removed from the thread pool. This ensures over-threading is not done on the host machine.
Represents a thread pool which is implemented to wrap .NET thread pool
This class is a remnant / adaptation of the original thread pool service from OpenIZ because OpenIZ used PCL which didn't have a thread pool. Additionally it provided statistics on the thread pool load, etc. This has been refactored.
QueueUserWorkItem
void
Action<Object> action
Queues the specified action into the worker pool
QueueUserWorkItem
void
Action<TParam> action TParam parm
Queue user work item
GetWorkerStatus
void
Int32& totalWorkers Int32& availableWorkers Int32& waitingInQueue
Get worker status