如何在并发字典中存储频道

Question

这是一个相当棘手的问题，但我试图理解的概念相当简单。

我有一个 public 静态并发字典，可从其他 classes 和线程访问：

public static readonly ConcurrentDictionary<int, object> tcpServerChannelDictionary = new ConcurrentDictionary<int, object>();

我有一个特定的后台线程，我最初在其中创建一个新的 C# 通道并将实例存储在字典中。在同一个线程中（以相同的方法），我然后开始异步等待消息。从方法中删除了一些不必要的代码膨胀：

var myChannel = Channel.CreateUnbounded<string>();
            tcpServerChannelDictionary.TryAdd(int, myChannel);

await foreach (var data in myChannel.Reader.ReadAllAsync())
{
    // Do something with message
}

第一个绊脚石是我无法将带有“对象”的静态字典定义为通道，即 ConcurrentDictionary... 因为我会收到一个警告标志“通道：静态类型不能用作类型参数”，所以这就是为什么我改为声明对象类型的原因。

这似乎在没有 VS 代码警告的情况下工作，直到我尝试从另一个 class（以及将是另一个线程）访问字典对象：

if (TcpServer.tcpServerChannelDictionary.TryGetValue(int, out Channel myChannel))
{
   await myChannel.Writer.WriteAsync(data);
}

我不知何故需要将对象投射到我试图访问的频道以便我可以向它写消息，或者需要一些其他的解决方案来防止警告。我是频道的新手，但立即看到了使用频道的强大功能。

Answer 1

Channel class 是一个带有工厂方法的辅助静态 class。所有这些方法 return 一个 Channel<T>。在您的情况下，您正在创建 Channel<string> 对象，这是一种可以从中构造字典的类型。

public static readonly ConcurrentDictionary<int, Channel<string>> tcpServerChannelDictionary = new();
//... 
if (TcpServer.tcpServerChannelDictionary.TryGetValue(int, out var /*Channel<string>*/ myChannel)) 
{
   await myChannel.Writer.WriteAsync(data);
}

现在，如果出于某种原因您仍然需要使用 object 类型作为字典的值（也许您对 Channel<T> 有不同的通用参数并且您希望它们都在同一个集合中) 你的 out 变量仍然需要是 object 然后你需要转换它：

if (TcpServer.tcpServerChannelDictionary.TryGetValue(int, out var /*object*/ oChannel) && oChannel is Channel<string> myChannel)
{
   await myChannel.Writer.WriteAsync(data);
}

如何在并发字典中存储频道

How to store a Channel in a Concurrent Dictionary

c#

system.threading.channels