jjzjj

multithreading - 戈朗 : can WaitGroup leak with go-routines

coder 2024-07-14 原文

我计划实现一个 go-routine 并有一个 sync.WaitGroup同步创建的 go-routine 的结尾。我基本上使用 go <function> 创建了一个线程.所以它是这样的:

main() {
    var wg sync.WaitGroup
    for <some condition> {
        go myThread(wg)
        wg.Add(1)
    }
    wg.wait()
}

myThread(wg sync.WaitGroup) {
    defer wg.Done()
}

我之前曾与 pthread_create 合作过在某些情况下确实无法创建线程。在这种情况下，是否可能针对上述 go myThread(wg)无法启动和/或运行 wg.Done() 例程的其余部分是否正常运行？如果是这样，将报告什么以及如何捕获错误？我担心 wg 中可能存在泄漏由于wg.Add(1)在线程创建之后。 (当然可以在函数内使用 wg.Add(1)，但这会导致增量和主程序等待之间的其他竞争)。

我已经阅读了大量关于 go-routines 的文档，但没有提到任何地方的调度或线程创建失败。如果我创建数十亿个线程并耗尽簿记空间，情况会怎样？ go-routine 是否仍然有效并且线程是否仍然被创建？

最佳答案

我不知道有什么可能的方法会导致失败，如果可能的话，它会导致 panic (并因此导致应用程序崩溃)。我从未见过它发生，而且我知道运行 数百万 goroutines 的应用程序示例。唯一的限制因素是分配 goroutine 堆栈的可用内存。

go foo() 不像 pthread_create。 Goroutines 是由 Go 运行时处理的轻量级绿色线程，并计划在 OS 线程上运行。启动 goroutine 不会启动新的操作系统线程。

关于multithreading - 戈朗 : can WaitGroup leak with go-routines，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/45803373/

multithreadinggo-routinescodesectionWaitGroupgoconcurrency

有关multithreading - 戈朗 : can WaitGroup leak with go-routines的更多相关文章

  1. ruby - Rack 并发 - rack.multithread、async.callback 或两者兼而有之？ - 2

    我试图完全理解Rack中并发请求处理的选项。我已经使用async_sinatra构建了一个长轮询应用程序，现在正在使用throw:async和/或Thin的--threaded标志试验裸机Rack。我对这个主题很满意，但有些事情我就是无法理解。(不，我没有将并发误认为是并行，是的，我确实理解GIL强加的限制)。Q1。我的测试表明thin--threaded(即rack.multithread=true)在单独的线程中同时运行请求(我假设使用EM)，这意味着长时间运行的请求A将不阻止请求B(IO放在一边)。这意味着我的应用程序不需要任何特殊编码(例如回调)来实现并发(再次忽略阻塞数据库调

  2. 戈朗 "Log in to the site and download the xls file"？ - 2

    关闭。这个问题需要更多focused.它目前不接受答案。想改进这个问题吗？更新问题，使其只关注一个问题editingthispost.关闭3年前。Improvethisquestion告诉我如何使用Golang登录网站。下载xls文件是得到了，但是为了在Excel表格中有数据，需要登录网站。该站点位于公司的服务器上。如果你能告诉你怎么做。例如，我用来执行此操作的VBA代码。SetoFields=CreateObject("Scripting.Dictionary")WithoFields.Add"login","sdiscor".Add"password","sdiscor"EndWi

  3. arrays - 戈朗 : Could not understand how below code is executing - 2

    下面是我查询的代码:我有一个单维数组a当我打印a[0][0]时，我不明白为什么它返回字符a的ascii值:packagemainimport("fmt")funcmain(){a:=[3]string{"a","b","c"}fmt.Println(a[0][0])}输出:97 最佳答案 下面是如何打印ascii的代码示例a:=[3]string{"a","b","c"}for_,rune:=rangea{fmt.Println(rune)//Itwillprinta,b,c}因为你在你的代码中使用了[0][0]，所以它是等价的fo

  4. 戈朗 :which way is more efficient about using "for range" - 2

    typepath[]bytefunc(ppath)ToUpper(){fori,b:=rangep{if'a'在上面(这个例子是从“TheGoBlog”复制过来的)，如果ToUpper变成这样:func(ppath)ToUpper(){fori,_:=rangep{if'a'哪个会更有效率为什么？“TheGoBlog”对前一个说:“这里的ToUpper方法在forrange构造中使用两个变量来捕获索引和slice元素。这种形式的循环避免了在主体中多次写入p[i]。”什么意思？ 最佳答案 前者有更多的内存操作，即在b上:它在循环的第一

  5. 戈朗 : go command inside script? - 2

    我有一个用Golang编写的脚本，我不太明白。我想知道他为什么要在脚本里面写goserver.Start()？为什么不简单地编写server.Start？packagemainimport("github.com/miekg/dns""testing""time")constTEST_ADDR="127.0.0.1:9953"funcTestDNSResponse(t*testing.T){server:=NewDNSServer(&Config{dnsAddr:TEST_ADDR,})goserver.Start()//Allowsometimeforservertostarttim

  6. multithreading - 引用计数资源的线程安全映射 - 2

    关闭。这个问题需要更多focused。它目前不接受答案。想要改进这个问题？更新问题，使其只关注editingthispost的一个问题。关闭5年前。Improvethisquestion关于管理资源集合:可通过全局列表(例如HashMap)按名称访问从多个线程同时访问引用计数(Golang缺少“弱引用”；参见https://groups.google.com/forum/#!topic/golang-nuts/PYWxjT2v6ps)例子:vartheListtMap//global//inthreadA,B,CetcaThing:=theList.ref("aThing")//ife

  7. 戈朗 : Is there a way to modify one of the multi-value return parameters in one line? - 2

    我正在尝试在Go中做一些相对简单的事情——将字符串转换为整数，然后将其加倍:myInt,_:=strconv.Atoi(args[1])doubleArg:=myInt*2由于Atoi()返回两个参数(整数和err)，我使用myInt,_:=来检索值的整数。我想将它加倍(因此是第二行)但不能在一行中完成所有操作:myInt,_:=strconv.Atoi(args[1])*2给我:multiple-valuestrconv.Atoi()insingle-valuecontext但是，根据我使用大多数其他语言的经验，必须在两行中执行此操作似乎有很多样板。这只是我必须处理的一个限制，还是有

  8. elasticsearch - 戈朗错误 "not enough arguments in call" - 2

    我刚接触golang。尝试通过golang实现批量上传到Elasticsearch。我正在使用golang库->https://github.com/olivere/elastic用于与Elasticsearch通信。此外，我正在尝试一段示例代码，但出现以下错误...suresh@BLR-245:~/Desktop/tools/golang/src$goinstallgithub.com/crazyheart/elastic-bulk-upload#github.com/crazyheart/elastic-bulk-uploadgithub.com/crazyheart/elasti

  9. multithreading - 戈朗 : can WaitGroup leak with go-routines - 2

    我计划实现一个go-routine并有一个sync.WaitGroup同步创建的go-routine的结尾。我基本上使用go创建了一个线程.所以它是这样的:main(){varwgsync.WaitGroupfor{gomyThread(wg)wg.Add(1)}wg.wait()}myThread(wgsync.WaitGroup){deferwg.Done()}我之前曾与pthread_create合作过在某些情况下确实无法创建线程。在这种情况下，是否可能针对上述gomyThread(wg)无法启动和/或运行wg.Done()例程的其余部分是否正常运行？如果是这样，将报告什么以及如

  10. go - 同步Go Routines需要什么 - 2

    这个特殊的Go代码使用一个channel来同步goroutines。//Wecanusechannelstosynchronizeexecution//acrossgoroutines.Here'sanexampleofusinga//blockingreceivetowaitforagoroutinetofinish.packagemainimport"fmt"import"time"//Thisisthefunctionwe'llruninagoroutine.The//`done`channelwillbeusedtonotifyanother//goroutinethatthi

随机推荐