登录
首页 >  Golang >  Go问答

用传统方式设立带有额外符号的频道

来源:stackoverflow

时间:2024-02-18 11:06:31 476浏览 收藏

亲爱的编程学习爱好者,如果你点开了这篇文章,说明你对《用传统方式设立带有额外符号的频道》很感兴趣。本篇文章就来给大家详细解析一下,主要介绍一下,希望所有认真读完的童鞋们,都有实质性的提高。

问题内容

tl;dr 我想要一个功能,其中通道有两个额外字段,告诉生产者是否允许发送到通道,如果允许,则告诉生产者消费者期望什么值。虽然我知道如何使用共享内存来做到这一点,但我相信这种方法违背了 go 的“不要通过共享内存进行通信;相反,通过通信来共享内存”的思想。

上下文:

我希望有一个服务器 s 运行(除了其他)三个 goroutine:

  1. 仅接收 udp 数据包并将其发送到解复用器的侦听器。
  2. 多路分离器接收网络数据包并根据某些数据将其发送到多个通道之一
  3. 处理任务,监听一个特定通道并处理该通道上接收到的数据。

为了检查网络上的某些设备是否仍然存在,处理任务将定期通过网络发送随机数,然后等待 k 秒。在这 k 秒内,收到随机数的协议的其他参与者将发送包含(除了其他信息之外)随机数的回复。解复用器将从侦听器接收数据包,解析它们并将它们发送到 processing_channel。 k秒过去后,处理任务处理解复用器推送到processing_channel上的消息。

我希望解复用器不只是盲目地将其收到的任何响应(正确类型)发送到 processing_channel 上,而是检查处理任务当前是否期望任何消息,如果是的话,它期望哪个随机数值。我做出这个设计决定是为了尽快丢弃不需要的数据包。

我的方法:

在其他语言中,我会有一个包含以下字段的类(以伪代码形式):

class ActivatedChannel{
    boolean    flag_expecting_nonce;
    int        expected_nonce;
    LinkedList chan;
}

解复用器在收到正确类型的数据包后,只需获取 activatedchannelprocessing_channel 对象的锁,检查标志是否已设置且随机数是否匹配,如果是,则将消息添加到 linkedlist chan

问题:

这种方法使用了锁和共享内存,这与 golang 的“不要通过共享内存进行通信;相反,通过通信来共享内存”的格言不符。。因此,我想知道...:

  1. ...对于 go 来说,我的方法是否“糟糕”,因为它依赖于共享内存。
  2. ...如何以更像 go 的方式实现概述的结果。

正确答案


是的,您描述的方法与 golang 的惯用实现方式不符。您正确地指出,在上述方法中,您是通过共享内存进行通信的。

要以 go 的惯用方式实现此目的,其中一种方法可能是您的 de multiplexer “记住”所有需要随机数的 processing_channels 和随机数的相应类型。每当 processing_channels 准备好接收回复时,它就会向 de multiplexe 发送一个信号,表示它正在等待回复。

由于 de multiplexer 是所有通信的中心,因此它可以维护 processing_channel 与它期望的相应随机数之间的映射。它还可以维护所有等待回复的 processing_channels 的“注册表”。

在这种方法中,我们通过通信共享内存

为了传达 processing_channel 正在等待回复,可以使用以下 struct

type ChannelState struct {
    ChannelId        string // unique identifier for processing channel
    IsExpectingNonce bool
    ExpectedNonce    int
}

在这种方法中,没有使用锁。

文中关于的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《用传统方式设立带有额外符号的频道》文章吧,也可关注golang学习网公众号了解相关技术文章。

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>