- mongodb - 在 MongoDB mapreduce 中,如何展平值对象?
- javascript - 对象传播与 Object.assign
- html - 输入类型 ="submit"Vs 按钮标签它们可以互换吗?
- sql - 使用 MongoDB 而不是 MS SQL Server 的优缺点
Goroutines 在 channel 上阻塞的顺序是否决定了它们解除阻塞的顺序?我不关心发送的消息的顺序(它们保证是有序的),但会解除阻塞的 Goroutines 的顺序。
想象一个在多个 Goroutine(1、2 和 3)之间共享的空 Channel ch
,每个 Goroutine 都试图在 ch
上接收消息。由于 ch
为空,每个 Goroutine 都会阻塞。当我向 ch
发送消息时,Goroutine 1 会先解除阻塞吗?或者 2 或 3 可能会收到第一条消息? (反之亦然,Goroutines 试图发送)
我有一个 playground这似乎表明 Goroutines 阻塞的顺序是它们被解除阻塞的顺序,但我不确定这是否是由于实现而导致的未定义行为。
最佳答案
这是一个很好的问题——它涉及到并发设计时的一些重要问题。如前所述,根据当前的实现,您的具体问题的答案是基于 FIFO 的。它不太可能永远不同,除非实现者决定,比如说,后进先出法更好。
不过,无法保证。因此,您应该避免创建依赖特定实现的代码。
更广泛的问题涉及非确定性、公平和饥饿。
也许令人惊讶的是,基于 CSP 的系统中的非确定性并非来自并行发生的事情。 可能是因为并发,但不是因为是并发。相反,在做出选择时会出现不确定性。在 CSP 的形式代数中,这是在数学上建模的。幸运的是,您无需了解数学即可使用 Go。但在形式上,两个 goroutine 代码是并行执行的,只要排除所有选择,结果仍然可以确定。
Go 允许选择通过 select
显式引入非确定性,并通过在 goroutine 之间共享的 channel 末端隐式引入非确定性。如果你有点对点(一个读者,一个作者)的 channel ,就不会出现第二种。因此,如果它在特定情况下很重要,您可以做出设计选择。
公平和饥饿通常是同一枚硬币的两面。饥饿是那些可能导致性能不佳,更有可能导致错误行为的动态问题之一(以及死锁、活锁和竞争条件)。这些动态问题是不可测试的 (more on this),需要一些水平分析来解决。显然,如果系统的一部分因为无法访问某些资源而没有响应,那么在管理这些资源时需要更加公平。
由于当前的 FIFO 行为,对 channel 端的共享访问很可能提供一定程度的公平性,这似乎就足够了。但是如果你想要保证它(不管实现的不确定性),可以使用 select
和数组中的点对点 channel 包。公平索引很容易实现,方法是始终按将最后选择的放在堆底部的顺序优先选择它们。此解决方案可以保证公平,但可能会带来很小的性能损失。
(旁白:参见 "Wot No Chickens" 英国坎特伯雷的研究人员发现了一个关于 Java 虚拟机的公平性缺陷的有趣发现 - 该缺陷从未得到纠正!)
关于go - 单 channel 上的 Goroutine 解锁顺序,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/25860633/
我很好奇为什么以下不起作用。一般select用default:防止死锁,但在这种情况下不是: package main import "fmt" func main () { a := mak
我一生都无法弄清楚如何切换图像排序。图像以 (x,x,3) 格式读取,theano 要求它是 (3,x,x) 格式。我尝试更改顺序numpy.array([img[:,:,i] for i in ra
我正在向 libnl 发送单个 SSID 和频率进行扫描,但我得到了多个扫描结果以及我请求的 SSID 和频率,但我需要单个扫描结果(仅适用于请求的 SSID),如何实现这一点。请帮助我,我也发送了我
我是 Golang 的新手,但正在努力理解这门伟大的语言!请帮帮我.. 我有 2 个 channel 。 “进”和“出” channel in, out := make(chan Work),
例如我有这段代码: package main import ( "fmt" ) func main() { c1 := make(chan interface{}) close
我们使用以下调用来获取经过身份验证的用户的 ChannelID,它适用于大多数情况。一些 YouTube 用户将他们的 channel 连接到 Google+ 信息页,但在这种情况下,我们的一位用户无
case 'sinfo': const sinfo = new Discord.MessageEmbed() .addField('Server Name 🔎 :', message.guild.n
我需要让所有 channel 来创建一个 bunker 命令,这使得所有 channel 都是只读的。 最佳答案 他们变了Client.servers至 Client.guilds在 newer ve
为什么当第二个值通过另一个 go routine 发送并且没有收到发送的第一个值时, channel c 没有缓冲? package main import "fmt" func sum(s []in
据我所知,内置的 split 会将一个 3 channel Mat 拆分为三个 1 channel Mat。结果,这三个 Mat 只是具有一些不同强度的灰度。 我的意图是获得三个 3 channel
如何检测当前的 RAM 配置?我需要询问 Windows RAM 当前是在单 channel 、双 channel 还是四 channel 中运行。 我搜索了很多,并没有在这个网站或其他网站上找到任何
我需要拆分一个多 channel wav 文件并将每个 channel 编码为 mp3 文件。 我知道 gtresamer 的 deinterleave 插件,但我不确定如何将它用于 wav 文件以及
关闭。这个问题需要details or clarity .它目前不接受答案。 想要改进这个问题吗? 通过 editing this post 添加详细信息并澄清问题. 关闭 8 年前。 Improve
我正在尝试运行 Hyperledger Fabric 网络,它由单个订购者、单个对等节点和一个 cli 组成。为了学习启动 Hyperledger Fabric 网络的过程,从创建与加密相关的工件到将
我在 Laravel 中使用事件广播。我正在使用基于角色的通知访问权限。我有用于广播的自定义 auth guard。当用户连接到 channel 时,客户端将具有内部权限的 access_token
我正在编写一个使用 Elixir Channels 来处理实时事件的应用程序。我知道每个客户端将打开 1 个套接字,并且可以在其上多路复用多个 channel 。所以我的应用程序是一个聊天应用程序,其
我有一些 .wav 文件,我想转换它们的频率 (fs) 和 channel 数 (nchannels)。我在jupyter笔记本python3.6上使用ffmpeg。我使用了以下命令并且它有效。 cm
我有一个视频渲染器,它需要两个 H265 流(YUV420),我需要烘焙它们以使它们中的一个与另一个形成 alpha 蒙版。这一切都已解决并且效果很好,但是如果我按照此处的说明进行操作: ffmpeg
我运行此命令以便能够将 udp 直播流传输到可使用正在构建的移动应用程序播放的 http 直播流。 它只是一个只有音频流的流。 ffmpeg -i udp://@localhost:1111 -map
我在我的 discord.js 机器人中创建了 nuke 命令,它创建了具有相同名称、权限、主题等的 channel ,并删除了“原始” channel 。但是有一个问题,如何使 channel 与“
我是一名优秀的程序员,十分优秀!