NTDLS.DelegateThreadPooling
1.5.0
See the version list below for details.
dotnet add package NTDLS.DelegateThreadPooling --version 1.5.0
NuGet\Install-Package NTDLS.DelegateThreadPooling -Version 1.5.0
<PackageReference Include="NTDLS.DelegateThreadPooling" Version="1.5.0" />
paket add NTDLS.DelegateThreadPooling --version 1.5.0
#r "nuget: NTDLS.DelegateThreadPooling, 1.5.0"
// Install NTDLS.DelegateThreadPooling as a Cake Addin #addin nuget:?package=NTDLS.DelegateThreadPooling&version=1.5.0 // Install NTDLS.DelegateThreadPooling as a Cake Tool #tool nuget:?package=NTDLS.DelegateThreadPooling&version=1.5.0
NTDLS.DelegateThreadPooling
📦 Be sure to check out the NuGet package: https://www.nuget.org/packages/NTDLS.DelegateThreadPooling
High performance active thread pool where work items can be queued as delegate functions. Allows you to easily enqueue infinite FIFO worker items or enforce queue size, wait on collections of those items to complete, and total control over the pool size. Also allows for multiple pools, so that different workloads do not interfere with one another.
If you have ever been frustrated with System.Threading.ThreadPool, then this is likely the solution you are looking for.
private static readonly DelegateThreadPool _delegateThreadPool = new(10);
static void Main()
{
CollectionExample();
NoCollectionExample();
Console.WriteLine("Press [enter] to exit.");
Console.ReadLine();
_delegateThreadPool.Dispose();
}
private static void CollectionExample()
{
Console.WriteLine("CollectionExample: Starting to enqueue items...");
var childPool = _delegateThreadPool.CreateChildPool();
//Enqueue work items as delegate functions.
for (int i = 0; i < 100; i++)
{
childPool.Enqueue(() =>
{
Thread.Sleep(1000); //Do some work...
});
}
Console.WriteLine("Enqueue complete, waiting on completion.");
//Wait on all of the workitems to complete.
childPool.WaitForCompletion();
Console.WriteLine("All workers are complete.");
}
private static void NoCollectionExample()
{
Console.WriteLine("NoCollectionExample: Starting to enqueue items...");
var itemStates = new List<QueueItemState<object>>();
//Enqueue work items as delegate functions.
for (int i = 0; i < 100; i++)
{
var queueItemState = _delegateThreadPool.Enqueue(() =>
{
Thread.Sleep(1000); //Do some work...
});
itemStates.Add(queueItemState);
}
Console.WriteLine("Enqueue complete, waiting on completion.");
//Wait on all of the workitems to complete.
itemStates.ForEach(t => t.WaitForCompletion());
Console.WriteLine("All workers are complete.");
}
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net6.0 is compatible. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 is compatible. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 is compatible. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. |
-
net6.0
- NTDLS.Semaphore (>= 3.4.2)
-
net7.0
- NTDLS.Semaphore (>= 3.4.2)
-
net8.0
- NTDLS.Semaphore (>= 3.4.2)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last updated |
---|---|---|
1.5.8 | 84 | 10/22/2024 |
1.5.7 | 77 | 10/20/2024 |
1.5.6 | 91 | 10/20/2024 |
1.5.5 | 87 | 10/13/2024 |
1.5.4 | 84 | 10/13/2024 |
1.5.3 | 80 | 10/13/2024 |
1.5.1 | 89 | 10/8/2024 |
1.5.0 | 86 | 10/3/2024 |
1.4.9 | 83 | 10/3/2024 |
1.4.8 | 155 | 8/25/2024 |
1.4.7 | 136 | 8/24/2024 |
1.4.6 | 111 | 8/23/2024 |
1.4.5 | 110 | 8/23/2024 |
1.4.4 | 123 | 8/13/2024 |
1.4.3 | 119 | 8/13/2024 |
1.4.2 | 119 | 8/13/2024 |
1.4.1 | 118 | 8/13/2024 |
1.4.0 | 112 | 8/12/2024 |
1.3.6 | 109 | 8/9/2024 |
1.3.5 | 103 | 8/9/2024 |
1.3.4 | 102 | 8/9/2024 |
1.3.3 | 112 | 8/9/2024 |
1.3.2 | 80 | 8/6/2024 |
1.3.1 | 81 | 8/6/2024 |
1.3.0 | 71 | 8/6/2024 |
1.2.15 | 121 | 6/20/2024 |
1.2.14 | 119 | 6/20/2024 |
1.2.13 | 192 | 3/12/2024 |
1.2.12 | 176 | 3/12/2024 |
1.2.11 | 267 | 2/22/2024 |
1.2.10 | 231 | 2/20/2024 |
1.2.9 | 307 | 1/24/2024 |
1.2.8 | 305 | 1/24/2024 |
1.2.7 | 301 | 1/24/2024 |
1.2.6 | 277 | 1/22/2024 |
1.2.5 | 294 | 1/22/2024 |
1.2.4 | 316 | 1/22/2024 |
1.2.3 | 319 | 1/22/2024 |
1.2.2 | 269 | 1/22/2024 |
Added performance and thread evaluation.
Fixed child pool overload for limiting queue size.