Channel.CreateUnboundedPrioritized Method

Author: ibrahimatay

CreateUnboundedPrioritized/CreateUnboundedPrioritized.csproj

@@ -0,0 +1,10 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <OutputType>Exe</OutputType>
+        <TargetFramework>net9.0</TargetFramework>
+        <ImplicitUsings>enable</ImplicitUsings>
+        <Nullable>enable</Nullable>
+    </PropertyGroup>
+
+</Project>

CreateUnboundedPrioritized/Program.cs

@@ -0,0 +1,26 @@
+// Channel.CreateUnboundedPrioritized Method
+// https://learn.microsoft.com/en-us/dotnet/api/system.threading.channels.channel.createunboundedprioritized?view=net-9.0
+
+// [API Proposal] Channel.CreateUnboundedPrioritized #62761
+// https://github.com/dotnet/runtime/issues/62761
+
+// Concurrent collection with priority
+// https://stackoverflow.com/questions/23470196/concurrent-collection-with-priority
+
+using System.Threading.Channels;
+
+var channel = Channel.CreateUnboundedPrioritized<(int priority, string message)>();
+
+// Write sample messages
+await channel.Writer.WriteAsync((2, "Emergency service dispatch"));
+await channel.Writer.WriteAsync((1, "Routine check: Blood pressure measurement"));
+await channel.Writer.WriteAsync((3, "Heart attack alert!"));
+await channel.Writer.WriteAsync((3, "Fire alarm!"));
+
+channel.Writer.Complete();
+
+// Read and process messages based on priority
+await foreach (var item in channel.Reader.ReadAllAsync())
+{
+    Console.WriteLine($"Processing: {item.message} (Priority: {item.priority})");
+}

CsharpLangExamples.sln

@@ -95,6 +95,8 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Roslyn Analyzer", "Roslyn A
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "NewLINQMethodsCsharp10", "NewLINQMethodsCsharp10\NewLINQMethodsCsharp10.csproj", "{D7C23C3C-8B11-4E31-830F-17CD9670D49E}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CreateUnboundedPrioritized", "CreateUnboundedPrioritized\CreateUnboundedPrioritized.csproj", "{8D54CE39-9351-4F21-B5A2-1238973E63B3}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -277,6 +279,10 @@ Global
 		{D7C23C3C-8B11-4E31-830F-17CD9670D49E}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{D7C23C3C-8B11-4E31-830F-17CD9670D49E}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{D7C23C3C-8B11-4E31-830F-17CD9670D49E}.Release|Any CPU.Build.0 = Release|Any CPU
+		{8D54CE39-9351-4F21-B5A2-1238973E63B3}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{8D54CE39-9351-4F21-B5A2-1238973E63B3}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{8D54CE39-9351-4F21-B5A2-1238973E63B3}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{8D54CE39-9351-4F21-B5A2-1238973E63B3}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

README.md

@@ -20,7 +20,8 @@ Examples of C# programming, to track and stay up-to-date with the latest languag
       * `Index()` 
       * `CountBy()` 
       * `AggregateBy()`
-
+  * [CreateUnboundedPrioritized](CreateUnboundedPrioritized/Program.cs)
+  
 * C# 12 is supported on .NET 8 (November, 2023) 
   * [Primary constructors](PrimaryConstructors/Program.cs)
   * [Default values for parameters in lambda expressions](DefaultLambdaParameters/Program.cs)