如何解决如何在并发字典中存储频道
这里有一个相当棘手的问题,但我试图理解的概念相当简单。
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 代码警告的情况下工作,直到我尝试从另一个类(以及另一个线程)访问字典对象:
if (Tcpserver.tcpserverChannelDictionary.TryGetValue(int,out Channel myChannel))
{
await myChannel.Writer.WriteAsync(data);
}
我不知何故需要将对象投射到我试图访问的频道,以便我可以向它写一条消息,或者其他一些防止警告的解决方案。我是频道的新手,但立即看到使用它们会有多么强大。
解决方法
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);
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。