我正在使用context.Context来控制多个goroutine。goroutine监听context.Done()，然后立即打印日期字符串。该进程监听syscall.SIGHUP，它取消上下文，然后使用之前创建的上下文创建新的goroutine。 我认为当syscall.SIGHUP发出时，进程将打印一个日期字符串，但得到了两个。case <-sg: go printDate(ctx)
浏览 17提问于2019-09-02得票数 0
我按照下面的代码使用channels获得一个惰性的数字范围func iterator(n int, c chan int) {
for i := 0; i < n; i有什么安全的方法来检查范围是否是坏掉的，并在迭代器中停止for-循环？
浏览 3提问于2020-08-03得票数 0
回答已采纳
我正在尝试结束多个goroutine，一旦另一个goroutine关闭了一个通道。然而，在接收到close信号后，我最终陷入了无限循环。我不知道为什么。我知道使用context.Context是可行的，但我是通过关闭频道来尝试的。
浏览 1提问于2019-07-24得票数 0
我需要在每个函数调用中取消以前的任何goroutine。那该怎么处理呢？我已经看到了使用的通道，但我无法完全了解示例以及select语句是否必要。
期望的结果是只运行最后一个请求子任务。
浏览 1提问于2020-02-14得票数 0
回答已采纳
1回答
我试图在go中编写一个类似于cron的程序，并添加一个额外的条件，即给作业提供一个最大的运行时，如果一个函数超过这个持续时间，作业应该退出。这是我的全部密码： "fmt" "sync")
IDlog.Printf("Job %#v halted after %v", j.ID
浏览 3提问于2021-04-05得票数 0
2回答
我有一个创建user -> user job -> user contact的服务，对于用户工作和联系人，我通过包装go goroutine来包装他们的任务来创建， // create the user= nil { }
}() 我在那个goroutine中安装了context canceledpanic，然后我的服务器就停止了，但是如果我不使用goroutine，在创建过程中就没问题，有谁知道
浏览 25提问于2020-09-03得票数 0
这是来自golang上下文页的代码片段。func httpDo(ctx context.Context, req *http.Request, f func(*http.Response, error) error) error {// Run the HTTP request in a goroutine and pass the response to f.并在一个新的goroutine中处理它的响应。如果ctx.Done在gorouti
浏览 5提问于2020-08-19得票数 2
signal" sig := make(chan os.Signal, 1) <-sig当然，在发送中断程序的信号之前goroutine 1 [chan receive]: /home/user/project/src/main.go:5 +0x4d虽然我理解为什么读取int通道会</em
浏览 3提问于2020-06-12得票数 6
回答已采纳
1回答
从本质上讲，我希望在阻塞的呼叫和通道上执行select。 我知道我可以将阻塞的调用推入goroutine并通过通道等待结果，然而这感觉像是错误的解决方案。 有没有一种惯用的方式来写我遗漏的这篇文章？最理想的情况是： select { ... ...
}
浏览 21提问于2020-09-04得票数 3
回答已采纳
3回答
我有一个goroutine，它调用一个函数，并使用一个特殊的参数来启动或停止这个goroutine。我的问题是，这段代码从来不会停止我的goroutine，它会在每次新作业时创建。} quit <- true run <- true我如何停止我的例程
浏览 3提问于2017-03-01得票数 4
我试图将上下文从一个传入的gRPC端点传递到一个goroutine，该goroutine负责向外部服务发送另一个请求，但我从goroutine中的ctxhttp.Get函数调用接收到了Error occurred会如预期的那样成功，并且不会收到任何错误。似乎父函数的上下文一返回就被取消了，而且由于父函数在goroutine之前结束，传递给goroutine的上下文正在接收context cancel
浏览 1提问于2018-11-14得票数 4
我无法理解中这个例子的逻辑 // Run the HTTP request in a goroutine and pass the response to f.return ctx.Err() return err}
Done
浏览 3提问于2019-12-18得票数 5
1回答
我在“面向开发人员的Go工具和技术中的并发性”中看到了这段代码，其中提到了广播的用法，上下文是使用广播来唤醒三次外出。，它允许我们注册函数来处理来自条件的信号。每个处理程序都在自己的goroutine上运行，在确认该goroutine正在运行之前，订阅将不会退出。()似乎必须在gorouting的开头，否则会导致死锁错误，但是为什么呢？-更新
实际上，我们可以通过这样的方式去除订阅函数中的<
浏览 5提问于2022-02-24得票数 1
回答已采纳
为什么我的程序在使用退出状态2执行goroutine时会出现恐慌/自动关闭？var ( ctx context.Contextsynchronised := usecases.NewXbaseUsecaselog.Println("Fetch ->", count)})错误消息:恐慌:无法从零父级创建上
浏览 8提问于2021-12-22得票数 -2
据我所知，如果goroutines太忙，它们会阻止其他goroutine运行。goroutine，即不是真正的块？有没有办法实现一个新的方法，调用第三方代码(包括像findnextchangenotification这样的异步Win32 API，它依赖于waitforsingleobject或waitforsingleobject在这个特定的例子中，syscall将在完成后发出信号，我需要等到它完成，而不会耗尽所有其他goroutin
浏览 1提问于2014-01-14得票数 13
回答已采纳
3回答
我已经搜索过了，只找到了和，但没有解决我的问题。2016/07/29 15:59:46 m=getHello, i=311, end正如您所看到的，
浏览 0提问于2016-07-30得票数 11
回答已采纳
这里的目标是调用一个doWork，如果doWork花费了很长时间来计算，那么GetValueWithDeadline应该在超时后返回0，或者如果调用方调用cancel取消等待(这里主要是调用者)或返回在给定时间窗口中返回的值同样的场景可以用不同的方式来完成。(单独的goroutine睡眠，唤醒检查值等，互斥对象上的条件等等)但我真的想了解使用上下文的正确方法。我理解的通道语义，但在这里我无法达到预期的效果，默认情况调
浏览 1提问于2020-06-06得票数 1
回答已采纳
我想知道为什么我们需要运行wg.Wait() in goroutinefunc main() { }() }}
有人能解释我为什么要在另一个峡谷里等吗
浏览 2提问于2014-12-04得票数 7
回答已采纳
我想运行我的函数InsertRecords 30秒，并测试在给定时间内我可以插入多少条记录。
如何在x秒后停止处理InsertRecords，然后从我的处理程序返回结果？
浏览 0提问于2018-11-02得票数 2
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
