goroutine 相关问题

goroutine是一个轻量级的执行线程,由Go语言运行时管理。

Worker pool pattern-deadlock

等待任务模式是池模式的基本模式。在下面的代码中:package main import(“ fmt”“ runtime”)//池化:您是一名经理,并且雇用了一组员工。 ...

回答 1 投票 -1

名为goruntine的runtime.gopark是什么?

我正在调试通过Goland用go编写的程序。在调试器中,我可以在正在运行的不同goroutine之间进行选择。我发现我的goroutine旁边还有很多其他的goroutine,它们的名称为...

回答 1 投票 -1

为什么不为golang包提供fini()函数? (已关闭)

有用于包装初始化的内置init()函数。为什么不破坏呢?例如,我在程序包中初始化了一个goroutine池,然后希望该池中的所有goroutine都完成...

回答 2 投票 -4

如何使用渠道收集各种goroutine的响应

我是Golang的新手,我有一个使用WaitGroup和Mutex实现的任务,我想将其转换为使用Channels。对该任务的非常简短的描述是:像...

回答 2 投票 1

Golang例行程序节流阀示例

我正在通过Udemy课程学习基本的golang。在goroutines部分中,有一个节流示例,使我对等待组的工作方式有所了解。包主要导入(“ fmt” ...

回答 1 投票 0

操作系统例程在io上是否阻塞OS线程?

我的机器上有4个逻辑处理器。因此有四个上下文P1,P2,P3和P4与OS线程M1,M2,M3和M4一起使用$ lscpu体系结构:x86_64 CPU op-mode:32 -...

回答 1 投票 0

例程等待通道的响应并继续

我正在学习go并发性,我想实现一个简单的示例,该示例从矩阵中获取行并将值的数组(切片)添加到每一行。由于我正在使用频道,因此我尝试等待每个频道...

回答 3 投票 0

如何防止sync.Pool创建两个实例

我正在实现一个TCP连接池,用于登录到fluent位,这是代码导入(“ fmt”“ log”“ net”“ sync”)类型FluentConnectionPool struct {sync.Mutex pool ...

回答 1 投票 -2

没有将选择中的通道发送值准备好

package main import(“ fmt”“ time”)func main(){ch:= make(chan int)go func(){fmt.Printf(“ func at%d \ n”,time.Now()。 UnixNano())选择{case ch

回答 2 投票 0

等待组中的一个goroutine发生第一个错误时如何退出?

func getRecords(ctx context.Context,ids * [] Id)错误{ctx,cancel:= context.WithTimeout(ctx,DefaultTimeout)defer cancel()var wg sync.WaitGroup size:= len(* ids)allErrors: = ...

回答 1 投票 1

为什么不为golang软件包提供fini()函数?

有用于包装初始化的内置init()函数。为什么不破坏呢?例如,我在程序包中初始化了一个goroutine池,并且希望该池中的所有goroutine都完成...

回答 2 投票 -4

这个goroutine如何连续运行(它如何工作?)>

我对goroutine的基本理解是,它是创建线程的简化方法。以confluent-kafka-go库为例,给出以下代码:go func(){...

回答 1 投票 0

Golang(GO)通道问题,试图实现(复制)数据库/缓存查询方案

因此,我不熟悉通道,等待组,互斥锁等,并试图创建一个应用程序,该应用程序查询结构的一部分以获取数据,如果找到数据,则将其加载到映射中。我基本上是想...

回答 1 投票 0

WaitGroups等待的时间不足以下载文件

根据输出判断,waitgroup wg没有足够的时间来下载文件。我正在通过副本将参数传递给goroutine。我正在等待带有等待功能的wg:var links = [...] ...

回答 1 投票 0

在不同结构中声明多个* sync.Mutex变量

为了使我的程序更高效,我可以将* sync.Mutex变量与结构相关联,以便当我执行a.Mutex.Lock()时,它仅锁定游戏服务器上的goroutines操作吗?还是不...

回答 1 投票 0

无互斥量的Go例程

尽管在写入共享资源时运行我的goroutine时没有任何互斥体,但是我没有遇到任何预期的运行时错误。相反,我得到了这个输出。 goroutine的输出...

回答 1 投票 -3

如何在vscode中调试goroutine?

请考虑以下小片段:包main import(“ fmt”“ sync”)func main(){var wg sync.WaitGroup wg.Add(2)go func(){defer wg.Done()for i:= 1; i&...

回答 1 投票 0

当访问相同结构的不同字段但在单独的goroutine中需要sync.Mutex吗?

我有一个结构,其中包含几个简单字段(即:int,string和[] byte)。我也有几个goroutines可以修改结构中的不同字段。但是每个goroutine都会修改自己的...

回答 1 投票 1


最大元素-致命错误:所有goroutine都在睡眠中-死锁

在我的机器上,NUMCPU为4。以下代码:包main import(“ fmt”“ sync”“ github.com/myhub/a/expressions”)var list = make([] int,1e5)func main() {value:= 0 for ...

回答 1 投票 -1

© www.soinside.com 2019 - 2024. All rights reserved.