GitCat.DataStructures
0.1.0
dotnet add package GitCat.DataStructures --version 0.1.0
NuGet\Install-Package GitCat.DataStructures -Version 0.1.0
<PackageReference Include="GitCat.DataStructures" Version="0.1.0" />
<PackageVersion Include="GitCat.DataStructures" Version="0.1.0" />
<PackageReference Include="GitCat.DataStructures" />
paket add GitCat.DataStructures --version 0.1.0
#r "nuget: GitCat.DataStructures, 0.1.0"
#:package GitCat.DataStructures@0.1.0
#addin nuget:?package=GitCat.DataStructures&version=0.1.0
#tool nuget:?package=GitCat.DataStructures&version=0.1.0
CommittableQueue<T>
A queue that groups completed elements together and emits the group when it reaches a specific size.
The idea behind this queue is that for lots of objects that should be processed only a limited number of checkpoints should be written. The queue takes all objects, waits until a group of objects is marked as completed, and then emits the latest completed object. Then for only this object a checkpoint can be written which in turn also marks all previous objects as successfully processed.
Imagine a CommittableQueue is initialized with a MinCompletionCount of four. After pushing a few objects into the queue (1 was pushed first), the queue might look like this:
[7, 6, 5, 4, 3, 2, 1]
Now some objects are marked as completed:
[7 ✔, 6, 5, 4 ✔, 3, 2 ✔, 1]
When completing object 3 all consecutively completed objects are grouped together resulting in a smaller list (saving memory) only the latest object of the group is kept:
[7 ✔, 6, 5, 4 ✔, 1]
When completing object 5, there are four objects completed in a row. As the object 1 is not yet completed, it is not allowed to emit the group:
[7 ✔, 6, 5 ✔, 1]
Now object 1 is completed and the object at the first dequeue-position is completed and also stands for at least minCompletionCount objects:
[7 ✔, 6, 5 ✔]
Therefore the object 5 is about to be dequeued (FIFO), completed and stands for at least 4 completed objects.
The object is now emitted by DequeueAsync(CancellationToken, bool) resulting in a queue like this:
[7 ✔, 6]
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net5.0 was computed. net5.0-windows was computed. net6.0 was computed. 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 was computed. 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. net9.0 was computed. net9.0-android was computed. net9.0-browser was computed. net9.0-ios was computed. net9.0-maccatalyst was computed. net9.0-macos was computed. net9.0-tvos was computed. net9.0-windows was computed. net10.0 was computed. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed. |
| .NET Core | netcoreapp2.0 was computed. netcoreapp2.1 was computed. netcoreapp2.2 was computed. netcoreapp3.0 was computed. netcoreapp3.1 was computed. |
| .NET Standard | netstandard2.0 is compatible. netstandard2.1 is compatible. |
| .NET Framework | net461 was computed. net462 was computed. net463 was computed. net47 was computed. net471 was computed. net472 was computed. net48 was computed. net481 was computed. |
| MonoAndroid | monoandroid was computed. |
| MonoMac | monomac was computed. |
| MonoTouch | monotouch was computed. |
| Tizen | tizen40 was computed. tizen60 was computed. |
| Xamarin.iOS | xamarinios was computed. |
| Xamarin.Mac | xamarinmac was computed. |
| Xamarin.TVOS | xamarintvos was computed. |
| Xamarin.WatchOS | xamarinwatchos was computed. |
-
.NETStandard 2.0
- Microsoft.VisualStudio.Threading (>= 17.10.48)
-
.NETStandard 2.1
- Microsoft.VisualStudio.Threading (>= 17.10.48)
-
net8.0
- Microsoft.VisualStudio.Threading (>= 17.10.48)
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 |
|---|