草庐IT

GoRoutines

全部标签

Go:所有 goroutines 都在 sleep - 死锁

我有一段代码来调整图像大小。我正在使用resize库。这是片段:packagemainimport("fmt""github.com/nfnt/resize""image""image/jpeg""os""runtime")funcmain(){runtime.GOMAXPROCS(4)file_names:=make([]string,5)fori:=1;i这是我的proccesFileName函数:funcproccesFileName(filenamestring,cchanstring,cechanerror){file,err:=os.Open(fmt.Sprintf("in

golang,goroutines,如何在另一个 channel 中设置 channel ,然后在关闭母 channel 后阅读

我是Golang的新手,但正在努力理解这门伟大的语言!请帮帮我..我有2个channel。“进”和“出”channelin,out:=make(chanWork),make(chanWork)我设置了在chanel中监听的goroutinesworker,捕获工作并完成它。我有一些工作,我会寄给香奈儿。当Work由worker完成时,它会写入Outchannel。funcworker(in当所有工作完成后,我会在程序写入时关闭两个channel。现在我想在OUTchannel中写完成工作的结果,但是在某些部分中将所有内容分开,例如,如果工作类型是这样的:typeWorkstruct{D

multithreading - 带有 goroutines 的 Golang 守护进程不会停止执行

我创建了一个守护进程,其目标是并行使用队列。为了测试它是否继续在后台执行,我实现了一个函数,该函数每10秒创建一个文件,直到它到达X,其中X是我为队列配置的最大进程数。队列的参数在config.yaml文件中定义。现在的问题是,即使我停止并删除守护进程,程序似乎仍在运行并创建文件...我尝试再次构建和运行程序,退出它,结束进程,删除文件,但似乎没有任何效果,文件不断在程序目录中创建。可以查看程序代码here,和配置文件here.你知道我该如何解决这个问题吗?提前致谢! 最佳答案 此代码将永远不会退出,直到它处理了len(queues

go - 使用 golang channel 。获取 "all goroutines are asleep - deadlock!"

我目前正在研究goroutines、channels和sync.WaitGroup。我知道waitgroup用于根据天气等待所有go例程完成wg.Done()已被调用足够多次以减少wg.Add()中设置的值。我写了一小段代码来尝试在golangPlayground上测试这个。显示如下varchannelchanintvarwgsync.WaitGroupfuncmain(){channel:=make(chanint)mynums:=[]int{1,2,3,4,5,6,7,8,9}wg.Add(1)goaddStuff(mynums)wg.Wait()close(channel)rec

goroutines 在打印 timecost 时相互影响

我是Golang的新生。我知道goroutine是一组抽象的cpu和内存来运行一段代码。所以当我在goroutine中运行一些计算函数(比如排序)时,我希望它们并行运行。但是打印的结果看起来很奇怪,“并行”代码打印的时间成本几乎相同。为什么?关于goroutine我是否遗漏了什么,或者是因为funcprintTime()?代码:https://play.golang.org/p/n9DLn57ftM附言应将代码复制到本地go文件并运行。那些在play.golang中运行的有一些限制。结果是:MaxProcs:8Source:2.0001msQuicksort:3.0002msMerge

go - 事情发生的顺序是什么?

我通过浏览官方网站上的围棋之旅开始接触围棋。我只有基本的编程经验,但在进入channel页面时,我开始四处游玩,试图了解它,结果我感到很困惑。这就是我的代码:packagemainimport"fmt"funcsum(s[]int,cchanint){sum:=0s[0]=8s=append(s,20)fmt.Println(s)for_,v:=ranges{sum+=v}c这是我得到的结果:7[8282040][82820][84020]263258[828840]我知道在创建一个slice时你会得到一个底层数组,下面有所需的数字,并将一个slice传递给一个函数并修改一个修改底层数

GoRoutines 并将结构传递给原始上下文

我有一个配置,它定义了一些实例(SomeConfigItems),每个实例都创建了一个thing()。那个东西是一个包含的包返回的结构,其中包含一个Price(float64)和一个嵌套结构。嵌套结构维护了一个交易图。问题是我能够遍历thing.Streams.Trades并从我的main()的for{}循环中实时查看所有交易。我看不到更新的东西。价格,即使它有时在处理程序中设置。我很难理解嵌套结构如何包含数据但不包含价格。我觉得好像我缺少一些关于范围、goroutines或可能是新对象实例化指针的东西。如有任何帮助,我将不胜感激,同时我会继续阅读。我已将代码缩减为看起来相关的内容。m

使用代理时会泄漏 goroutines

请帮助我解决我的问题。我写了检查代理的代码。一般来说,我运行50个goroutines,每个goroutines从channel获取代理并检查它是否工作并从我的测试页面得到正确的响应。每个goroutine都建立了这个关系请求---->代理--->我的测试页--->从我的测试页测试内容。检查这个关系的函数是://GetAndCheckURLgettestpageviaproxyandcheckitsbody.funcGetAndCheckURL(c*http.Client,urlStrstring)([]byte,error){resp,err:=c.Get(urlStr)iferr!

go - gotour并发教程中为什么需要goroutines的解释

我无法理解goroutines和channels在go之旅中的使用。引用以下代码:"https://tour.golang.org/concurrency/2"packagemainimport"fmt"funcsum(s[]int,cchanint){sum:=0for_,v:=ranges{sum+=v}c它使用前面带有“go”关键字的goroutines运行求和函数,但它们所做的只是将值发送到channel。它们不应该与goroutines一起运行。但是,当删除go关键字以正常运行函数时,出现此错误:fatalerror:allgoroutinesareasleep-deadlo

go - 为什么这段代码中会出现 fatal error : all goroutines are asleep - deadlock!?

这是引用Go编程语言中的以下代码-第8章p.238从下面复制自this链接//makeThumbnails6makesthumbnailsforeachfilereceivedfromthechannel.//Itreturnsthenumberofbytesoccupiedbythefilesitcreates.funcmakeThumbnails6(filenames为什么我们需要将closer放在goroutine中?为什么下面不能工作?//closer//gofunc(){fmt.Println("waitingforreset")wg.Wait()fmt.Println("c