时间戳

首页 > 解决方案 > 如何在并发字典中存储通道

c# - 如何在并发字典中存储通道

问题描述

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

我有一个公共静态并发字典，可以从其他类和线程访问：

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

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

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

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

第一个绊脚石是我无法将静态字典定义为“对象”作为通道，即 ConcurrentDictionary<int, Channel>... 因为我会收到警告信号“通道：静态类型不能用作类型参数" 所以这就是为什么我声明了一个对象类型。

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

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

在此处输入图像描述

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

标签： c#system.threading.channels

解决方案

该类Channel是一个带有工厂方法的辅助静态类。所有这些方法都返回一个Channel<T>. 在您的情况下，您正在创建Channel<string>对象，这是可以构造 Dictionary 的类型。

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);
}

推荐阅读