草庐IT

Goroutine-safe

全部标签

go - 组合使用goroutine

我正在尝试让代码工作,该代码几乎涉及goroutine中的channel(在C#中类似于yield的行为)代码涉及从slice中获取可迭代矩阵,如下所示:elements:=[]float64{1,2,3,4}expected:=[][]float64{{1},{2},{3},{4},{1,2},{1,3},{2,3},{1,4},{2,4},{3,4},{1,2,3},{1,2,4},{1,3,4},{2,3,4},{1,2,3,4},}我尝试通过以下方式应用Knuth:funcCombinadic(values[]float64)0{x=j}else{ifc[1]+1=t{brea

go - (goroutine 泄漏)http.TimeoutHandler 不会杀死相应的 ServeHTTP goroutine

超时处理程序在新的goroutine上移动ServeHTTP执行,但无法在计时器结束后终止该goroutine。对于每个请求,它都会创建两个goroutine,但ServeHTTPgoroutines永远不会用上下文杀死。无法找到杀死goroutines的方法。编辑带有time.Sleep函数的For循环,代表了超出我们计时器的巨大计算。可以用任何其他功能代替它。packagemainimport("fmt""io""net/http""runtime""time")typeapistruct{}func(aapi)ServeHTTP(whttp.ResponseWriter,req*

Golang 多个 goroutine 通过引用共享同一个变量

我正在尝试运行多个goroutine来修改通过引用传递的相同变量。但我确信我实现它的方式在功能上是不正确的。尽管它似乎在我的测试中有效,但我感觉如果第二个goroutine比第一个goroutine花费更长的时间运行,那么当第一个goroutine完成时,这种模式会结束父函数。我希望得到您的意见/建议/忠告。packageauthimport("regexp"zxcvbn"github.com/nbutton23/zxcvbn-go""golang.org/x/net/context")typeAuthServicestruct{}funcNewAuthService()*AuthSe

go - 在 go http 处理程序中使用 goroutine 和 channel 使 ResponseWriter 被阻塞

packagemainimport("fmt""log""net/http""time")varchchanboolfunctestTimer1(){gofunc(){log.Println("testtimer1")ch我写了上面的代码,把一个channel放到"myhandler"里面,channel就会当定时器任务已执行。然后我从channel获取数据并将“helloworld”写入httpwriter但是我发现客户端收不到“helloworld”,作者被屏蔽了!!!!!有人知道吗?在我的cmd上查看正在运行的图片:enterimagedescriptionhereenterim

go - 如何停止可能正在运行或未运行的 goroutine?

我有一个gofunc,如果它在默认情况下运行,我想停止它。以下方法在quit处被阻止如果gofunc已经返回。quit:=make(chanbool)gofunc(){for{select{case 最佳答案 关闭退出channel而不是发送值。循环将退出,因为在关闭的channel上接收返回零值。此外,将channel声明为chanstruct{}以指示channel值对程序不重要:quit:=make(chanstruct{})gofunc(){for{select{case如果你需要摆脱“其他东西”,那么将退出channel传

go - 有没有我们会求助于进程而不是 goroutine 的情况?

关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题?更新问题,以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我知道goroutine的重量很轻,我们可以生成数千个goroutine,但我想知道在某些情况下我们应该生成一个进程而不是goroutine(比如在资源方面达到某种进程边界或者是其他东西)。在某些情况下生成新进程是否有利于资源利用或其他方面?

go - golang 中的悬挂 goroutine

在下面的代码中goroutine1发生了什么?(在程序的最后我们有三个没有任何功能的goroutinegoroutine1)channel会发生什么?(当我们在循环中创建一个channel时,它会释放之前的channel内存?关闭它?还是其他?)funcmain(){fori:=1;i运行上面的代码here 最佳答案 对于i=1,循环创建两个goroutine,并开始等待从channel读取数据。goroutine2首先写入并终止。channel被读取,然后i变为2。goroutine1将永远等待,因为没有人会再次从channel读

multithreading - Go-尝试创建超过一定数量的goroutine时出现段错误问题

我试图在go中对http客户端进行压力测试。一开始,我只是尝试运行10个并发请求10次迭代。这是我的客户代码://stress.gopackagemainimport("fmt""io/ioutil""net/http""time")funcMakeRequest(urlstring,chchan对于迭代和goroutine的这种组合,它工作得很好。但是,当goroutine和迭代次数超过某个级别时,在我的例子中,对于单个迭代,当goroutine的次数超过634时,我收到这个错误:panic:runtimeerror:invalidmemoryaddressornilpointerd

multithreading - 在 Go 中使用 map 时忽略 goroutine/thread-safety 的危险是什么?

Go的map据说不是goroutine-safe(参见here和here)。我很想知道在我忽略使用互斥体/等来保护对map的访问的情况下会发生什么。具体,是否会发生以下任何情况?假设我有一个包含键k1、k2、...、kn的映射,并发问题是否会导致获取map[ki]当我请求map[kj](i!=j)时?它会导致应用程序出现panic吗? 最佳答案 正如评论已经指出的那样,比赛很糟糕。与Java不同,Go的保证非常弱,因此允许具有任何竞争的程序有未定义的行为即使包含竞争的代码未执行。在C语言中,这称为“catch-fire语义”。比赛的

multithreading - 多个 goroutine 会同时调用 Conn 上的方法吗?

我的程序是这样的:funchandle(connnet.Conn){msg:="hello,world!"fori:=0;i程序会同时运行100000个goroutines,所有goroutines都会向同一个连接发送消息。我怀疑服务器会收到像“helloheloworldworld”这样的错误消息,但是当程序在我的Ubuntu14.04LTS上运行时没有问题。那么,多个goroutine会同时调用一个Conn上的方法吗?=======================================================================如何使Write方法保持