jjzjj

goroutine

全部标签

go - http.Client 和 goroutines 的不可预测的结果

我是Golang的新手,试图构建一个系统,从一组url中获取内容并使用正则表达式提取特定行。当我用goroutines包装代码时,问题就开始了。我得到了不同数量的正则表达式结果,并且许多提取的行都是重复的。max_routines:=3sem:=make(chanint,max_routines)//tocontrolthenumberofworkingroutinesvarwgsync.WaitGroupch_content:=make(chanstring)client:=http.Client{}fori:=2;;i++{//fortestingifi>5{break}//loo

go - 带有 channel 的Goroutine的行为

下面给出的代码输出有些混乱,请帮助我理解通道和goroutine的行为以及如何执行实际上发生了。我试图理解程序的流程,但是执行了“调用goroutine”之后的语句,即使goroutine被调用了,稍后执行goroutines中的语句,在第二次“调用goroutine”时,行为不同,并且打印/程序流程的顺序发生了变化。以下是代码:packagemainimport"fmt"funcmain(){fmt.Println("1")done:=make(chanstring)gotest(done)fmt.Println("7")fmt.Println(上面代码的结果:17238109465

go - 在缓冲 channel 上使用范围时程序中的死锁

我正在学习Go,并且正在玩Goroutines和channel。我正在使用两个缓冲channel编写一个非常人为和天真的工作池,一个用于输入,一个用于输出。现在我在添加作业后关闭我的输入channel,然后最终读取输出channel以从中读取结果,但是当我使用forval:=rangech作为输出时程序因死锁而panic。这是示例代码packagemainimport("fmt""time")funcmain(){st:=time.Now()jobs:=make(chanint,100)res:=make(chanint,100)//Puttingitemstothejobschann

go - 当 parent 返回时停止子 goroutine

这个问题在这里已经有了答案:Stopgoroutineexecutionontimeout(3个答案)关闭3年前。我们有一个生成父goroutine的主go例程,父goroutine又生成一个子go例程。即使在父goroutine返回后,子goroutine仍然运行。这会导致goroutine泄漏。我们如何避免这种情况?下面我添加了一个代码片段来模拟以下内容这里的子goroutine可以是任何一个长时间运行的进程,比如数据库查询、api调用等Programoutput:Inmainfunction-1Startingparentfunction-2Startingchildfuncti

http - Go net listener 关闭及常规处理

我正在开始例行程序并在网络监听器(HTTP)上进行监听。我想关闭监听器,关闭例程并开始一个新例程,然后重新启动监听器。当我关闭监听器时,一切都乱套了。(listener是全局的)listener,_=net.Listen(CONN_TYPE,CONN_HOST+":"+CONN_PORT)goPassThrough()在哪里funcPassThrough(){verbose:=flag.Bool("v",false,"shouldeveryproxyrequestbeloggedtostdout")flag.Parse()proxy:=goproxy.NewProxyHttpServe

去新手 : how to run goroutines shell?

我尝试运行shell-basic但没有任何反应。这是我尝试过的:Torunthisexample,downloadandinstallitwithgoget:gogetgoroutines.com/shell-basic静默完成,我看到它下载了shell基本脚本,但是当我执行shell-basic时,我得到:$shell-basic-bash:shell-basic:commandnotfound我做错了什么,还是我遗漏了什么?我感兴趣的是将go作为scripts运行.. 最佳答案 goget将获取源并将其放入您的Go路径,在she

go - 一个 Go 程序可以同时启动 8k+ Goroutines 吗?

关闭。这个问题需要debuggingdetails.它目前不接受答案。编辑问题以包含desiredbehavior,aspecificproblemorerror,andtheshortestcodenecessarytoreproducetheproblem.这将有助于其他人回答问题。关闭5年前。Improvethisquestion我需要启动多个goroutines来发送http请求。以下是我的代码:funcInteractWithCheck(clusterIdint,tableNamestring,keystring,jobs=500{continue}deferresp.Bod

performance - Golang goroutine 在添加并发时变慢

我正在研究golang和goroutine的使用。使用此示例代码,在我具有4个逻辑CPU的PC上,我无法理解为什么我没有任何性能提升。如果我添加并发,那么它所花费的时间往往会比没有并发的原始时间慢。2017/10/2713:57:17Starting1threads2017/10/2713:57:27Idroutine:0rate:232.5581402017/10/2713:57:27Currenttotalratewas232.56K/s2017/10/2713:57:27Starting1threads2017/10/2713:57:37Idroutine:0rate:357.1

go - 如果调用的函数来自不同的包,如何同步 goroutine?

为了学习如何在Go中构建Web应用程序,我创建了一个小型Web应用程序,我在其中使用了Gorillamux,我主要在包main、handlers、model、structs下面。我想在浏览文档时使用goroutines我开始知道我需要使用sync包和gofun()。我尝试如下所示在同一个包中使用它并且工作正常。但是,如果调用的函数来自不同的包,如何同步goroutine?//samepackage:workingpackagemodelsimport("fmt""sync")varwgsync.WaitGroupfuncFunc1()(string,error){lexpiry:=Re

go - 取消用户特定的 goroutines

关闭。这个问题需要更多focused.它目前不接受答案。想改进这个问题吗?更新问题,使其只关注一个问题editingthispost.关闭4年前。Improvethisquestion我有一个应用程序(网络应用程序)让用户使用Twitteroauth登录并提供自动删除推文的功能。在用户登录到网络应用程序后,我将为每个将删除用户推文列表的用户启动一个goroutines(通过RESTapi)。假设有100个用户,每个用户有500+条推文:如何在删除过程中停止删除go例程。例如:用户30在启动删除过程2分钟后请求停止删除推文(这应该通过对我的应用程序的API调用来完成)。在考虑http请求