我有一个服务器，在收到请求时，它需要使用goroutine从不同的流中读取消息，将它们发送到父goroutine，父goroutine聚合消息并将其发送到客户端。|--> worker3 我使用不同的通道在所有这些goroutine之间通信，工作程序可以写入聚合通道，处理程序(父goroutine)可以接收它并将其发送回客
浏览 23提问于2021-03-30得票数 0
1回答
有两种类似的情况，我想与您进行比较--唯一的区别是处理值生成的方法。第一种情况:选择的情况之一中的值生成 "fmt" "time" generateValuesfmt.Println("Closing the channel") time.Sleep(5 * t
浏览 3提问于2022-01-29得票数 1
is closed }} 程序的输出由于通道的缓冲容量为5，并且我们在其中插入了6个元素，因此我期望它在读取值并清除缓冲区中的空间之前阻塞在resultStream <- i处。
浏览 15提问于2021-10-25得票数 0
回答已采纳
3回答
我想了解这里的日常工作是如何进行的。问题2:我还想知道如果我把“嗨，向上”发送到msg频道，为什么它没有收到行:13？*嗨，你好吗？金莲花1成龙收到：/Users//work/go/src/github.com/Golang_play/goroutine/goroutine.go:21 +0x1
浏览 1提问于2018-02-04得票数 1
回答已采纳
对于Go中缓冲频道和非缓冲频道之间的区别，我有点困惑。func() { messages <- "ping" }() fmt.Println(msg)另一方面，当我将"ping"传递给常规函数中的消息时chan string) msg := <-messages}
最后，当我使用
浏览 1提问于2020-07-02得票数 2
回答已采纳
2回答
goroutine 1 [chan send]: /tmp/sandbox994400718/main.go:16 +0x80
一个值被发送到通道，并在下一行被接收。
浏览 4提问于2015-11-08得票数 3
回答已采纳
我已经将通道缓冲区大小设置为零，就像var intChannelZero = make(chan int)一样，当从intChannelZero获取值时将被阻塞，直到intChannelZero有值为止另外，我将通道缓冲区大小设置为1，比如var intChannelOne = make(chan int, 1)，当从intChannelOne获取值时将被阻塞，直到intChannelOne有值为止。我们知道intChannelZero的容量是零，intChannelOne的容量是1，所以我想知道：
当将值放入intC
浏览 0提问于2018-11-17得票数 12
回答已采纳
1回答
我在Go中开始学习并发性，在阅读了一些示例之后，我想尝试一个系统，在这个系统中，每秒钟都会在终端中打印当前的时间，用户可以在终端中输入任何文本，并且在终端中打印出相同的文本(或者我们可以做任何其他的事情，比如，如果只写了一篇将被打印出来的特定文本)。基本上，我想出这个表单来编写我的代码：
函数输出每个secondGetInput:函数检查用户输入的时间，如果输入不是空的，获取它的值并将其放入另一个函数将要从一个值读取的变量中，如果值不
浏览 6提问于2022-07-07得票数 0
3回答
下面我有一个主要运行go例程的代码摘录。为什么没有发生这种情况:主退出在它收到完成后和作业返回之前，这将使子进程僵化。任何对戈朗文档的引用都是有帮助的。
浏览 4提问于2018-02-28得票数 0
回答已采纳
1回答
我已经在我的Go微服务中创建了一个NSQ生成器，并且我正在尝试为它创建一个方法，以便在NSQ重启后尝试重新连接。我查看了nsq配置文档，希望查看是否可以在重新启动/退出时提供故障转移方法，但我没有太多的运气。我将发布如何创建我的NSQ生成器： type ProducerNSQ struct {}
return nil, err return &Produ
浏览 35提问于2020-01-17得票数 0
4回答
下面是一个关于未缓冲通道的简单示例代码： fmt.Println("We are in the sub goroutine")}()
ch01 <- "Hello"Weare in the ma
浏览 1提问于2018-04-21得票数 4
回答已采纳
3回答
我发现如果我关闭了通道就不会有死锁，但我不知道为什么会这样。在通道中输入所有项目后，是否必须关闭通道？
浏览 10提问于2021-05-07得票数 2
3回答
我有几个函数，我希望它们能自动执行，因为它们处理敏感的数据结构。假设下面的场景:有两个函数：lock(sth)和unlock(sth)，它们可以随时被goroutine调用，以锁定或解锁全局数组中的sth。我在考虑有一个命令通道，这样goroutines就可以将lock和unlock命令发送到通道中，在通道的接收端，某种类型的handler通过从通道获取命令，依次处理lock和unlock请求。在一句话中：
在容量为
浏览 0提问于2017-06-08得票数 3
我把我的问题归结为下面这个简单的例子。我正在调用一个接收两个通道并向每个通道发送一个消息的goroutine。然后，我正试图进一步接收这些信息。然而，接收渠道的顺序是重要的。如果我使用与发送消息相同的顺序，程序将运行。如果我换了它就不会了。
我原以为戈鲁蒂能独立运行，不需要检索消息，我就可以从我想要的任何频道<
浏览 6提问于2022-02-22得票数 0
回答已采纳
2回答
通过渠道进行通信
、、
有一家主要的goroutine和十家子公司。他们都可以访问channel。主通道向该信道发送1000号码，子通道将从中读取。
浏览 0提问于2017-11-23得票数 0
回答已采纳
我有一个非常简单的围棋代码。我试着把结构和切片放在一起做围棋。我不确定这是否会是我在生产中使用的东西，但它似乎有点不对劲，所以在这里： routinemsg := make(chan []Person)
routinemsg2
浏览 12提问于2022-11-25得票数 0
回答已采纳
c := make(chan int)}
c<-3time.Sleep(time.Second)
我的代码不执行我的直觉是main在my_func完成执行之前返回，但是添加暂停似乎没有任何效果。我完全迷上了这个简单的例子，这是怎么回事？
浏览 5提问于2015-02-03得票数 12
回答已采纳
为什么我的代码在从通道读取时死锁(然后崩溃)，我希望它在通道完全读取后在读取时阻塞，但不会崩溃。我知道这是一种死锁状态，因为没有人在通道上写入和读取数据块。
浏览 36提问于2018-08-31得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
