我有一个包含[]string的list (containers/list)。我经常通过一个渠道发送这个信息。我正在试着理解这种交流有多昂贵。在发送时，正在发送的数据的浅拷贝被复制到缓冲区，然后在接收时在另一端重新复制，这是大体情况吗？那么，发送和接收并不比浅显的复制更昂贵？一般情况下有没有一些问题？
浏览 3提问于2017-01-27得票数 3
回答已采纳
1回答
我需要并行化我的for循环，它并行读取所有这些parquet文件，并通过并行读取所有这些拼图文件来填充地图。这些data结构中的并发映射将由多个读取器线程并发读取，并由多个作者在for循环中并行编写。我想确保它们是安全的，而且操作是原子的。我还得到了getter方法来访问这些并发映射。//....
pars3 "github.com&
浏览 8提问于2022-02-22得票数 0
回答已采纳
我有两组代码-读取包含随机文本行的文件，并将每行加载到一个通道。我不明白为什么会返回一个错误。案例1返回“致命错误:所有goroutines都处于休眠状态--死锁！”但是案例#是可行的。= nil {}go func() {
scanner := bufio.NewScanner(
浏览 2提问于2019-04-17得票数 0
我正在尝试使用信号量来解决goroutines上的死锁问题。我已经创建了两个写入无缓冲通道的函数。读数发生在主频道上。第三个函数用于关闭通道。close(ch) ch := make(chan string) wg.Add(3) go g(ch, c) for word :=
浏览 0提问于2020-08-22得票数 1
1回答
写到通道永远被阻塞
、、、
1000 * time.Millisecond)这是输出：routine 1beforex= 0before
go例程2将0写入通道c并等待，因为缓冲区大小为0，除非有人读取通道c，否则它将无法向其写
浏览 2提问于2017-01-21得票数 2
回答已采纳
基本上，我正在尝试使用goroutines编写一个并发的站点地图爬虫。一个站点地图可以包含指向多个站点地图的链接，这些站点地图可以包含指向其他站点地图的链接，等等。print(url) - create 10 workers问题是，worker在processUrl()完成之前不会从通道接受新的url，而processUrl只有在worker向通道添加url时才会完成，直到worker从通道接
浏览 7提问于2017-12-15得票数 2
回答已采纳
3回答
有人能给我一些关于这段代码的见解吗?为什么这是for x:=range c中的get死锁错误 c:=make(chan int,10)
go
浏览 28提问于2019-11-25得票数 0
回答已采纳
我正在创建一个带有go例程和通道的函数，它可以接受任何大小的数组，例如{100,122, 14, 64, ...}，它将从最后一个位置和前一个位置的数组之间找到较高的扣除值，依此类推。例如，64大于14，那么必须扣除它，你会得到更高的值，但它不会用比当前值高的值来扣除。int){ maxInteger := 0
for i := len(b)-1; i >0 ;i--
浏览 5提问于2021-01-19得票数 0
2回答
Go中的缓冲通道
、、
我正在做一个使用树莓派和arduino的项目。我正在raspberry pi上写一个GO程序，以便以每秒115200波特率接收来自Arduino的UART数据。raspberry pi读取UART数据，将其保存到一个文件(基于file1或file2等的值)，然后将该文件发送到ftp服务器。由于上传到服务器可能需要时间，这取决于网络，所以我想使用go并发，这样UART读取和保存到文件就不会中断。下面是我尝试应用的伪代码(框架)。我在代码中的</e
浏览 27提问于2019-08-14得票数 0
1回答
package main "fmt")
c := make(chan int)
c <- 10}
在上面的程序中，我创建了一个Go例程，它正在写入通道c，但没有其他go例程正在从该<
浏览 19提问于2020-05-07得票数 2
回答已采纳
1回答
我有一个TCP套接字和两个读写流的goroutines。我正在编写一个从通道读取数据的goroutine。如果TCP连接断开，则read from the go例程将检测到错误并停止。但是我如何释放一个有goroutine写入的通道呢？
有没有像chan.release()这样的方法，或者我应该发布一个特殊的数据包，告诉goroutine结束？
浏览 3提问于2013-02-13得票数 3
回答已采纳
我试图从循环中的goroutines收集错误，但不明白它如何正确地工作 rand.Seed(1500929006430687579) wg.Add(1) gofor k := 0; k < types; k++ { n := rand.Intn(2
浏览 6提问于2022-11-11得票数 0
回答已采纳
我正在构建一个go库，它管理数据并将数据写入文件。我已经编写了一个可以传递数据的文件编写器，它将通过一个缓冲的编写器将该数据写入文件。这意味着，一旦服务关闭，使用库的服务将不得不调用close方法来写入缓冲区中的任何内容。我看到了两种处理这个问题的方法：
公开服务可以使用的Close方法。使用通道。如果服务关闭通道</e
浏览 1提问于2021-11-16得票数 1
回答已采纳
1回答
我正在学习Go的并发模型，并从“学习Go”一书中看到一个例子-- Oreilly。在下面的示例中，"r := <- result“阻塞，直到任何Goroutines写入结果通道，并且由于结果是非缓冲通道，随后从其他Goroutines写入的结果将被阻塞，直到结果通道再次为空。我的问题是，如果有2个Goroutines并行运行并同时写入结果通道(结果当时是空的
浏览 3提问于2022-10-31得票数 0
虽然我也看到过类似的问题，但没有一个答案对我有帮助，但我希望一个善良的灵魂能用鹰眼帮助我找到这个问题。我知道这不是最好的使用哥鲁蒂，但我想这样做，作为一个演习，显然已经失败了。我的代码 "fmt" "sync" X := []int{1, 2, 3,chan<- int) {
wg.Add(
浏览 4提问于2020-06-28得票数 0
回答已采纳
1回答
我目前正在学习Go中的死锁以及它们何时出现。我在看这段代码。我知道这里有可能陷入僵局，但我找不到。谁能给我解释一下吗？func newsReader(reutersCh chan string, bloombergCh chan string) { gofunc() { }() ch <- (<-bloombergCh)
浏览 1提问于2022-01-30得票数 0
1回答
我正在编写一些Go软件，该软件负责下载和解析大量JSON文件，并将解析过的数据写入sqlite数据库。我目前的设计有10个go例程，同时下载/解析这些JSON并将它们通信到另一个go例程，后者的唯一工作是在特定频道上侦听并将通道内容写入DB。在完成所有写入之后，系统会执行一些额外的读取操作，这将导致查询返回不正确结果的问题，因为并非所有
浏览 3提问于2020-06-02得票数 2
回答已采纳
我有下面的程序作为概念的证明。我正在尝试聚合来自chann的结果，也就是说，将chann的每个实例合并到一个公共切片中。对于我的方法，这可能吗？因此，对于下面的示例，我的输出将是一个包含以下内容(按任意顺序)的切片：[]int{0,1,2}，谢谢。make(chan int[], 3) wg.Add(1)
go</e
浏览 3提问于2020-06-02得票数 0
回答已采纳
1回答
sum // send sum to c s := []int{7, 2, 8, -9, 4, 0}
go(x, y, x+y)大家好，这是官方网站上的频道使用示例。该示例启动2个go例程来计算子数组的和。然后，它将写入int通道。我<em
浏览 1提问于2018-10-18得票数 1
1回答
我创建了一个新的mongo会话，以及用于通信b/w go例程的两个通道，通道用于同步b/w readFile和main，而另一个通道则是将从readFile中读取的数据传递给db编写常规插入to 。= nil { }}
然后，启动goroutine readFile，它开始从输入文件读取数据，并将数据写
浏览 0提问于2018-06-08得票数 1
回答已采纳
云服务器
ICP备案
对象存储
腾讯会议
云直播
腾讯云开发者
