在GO中进行非阻滞睡眠

发布于 2025-02-06 07:58:51 字数 688 浏览 1 评论 0原文

在C＃中，当我们想在执行两个过程之间延迟时，我们有两个选项：

thread.sleep（time） blocking
等待task.delay（time） 是

换句话说，thread.sleep（time） 指定时间的当前线程时，等待task.delay（time）暂停执行线程（允许OS线程调度程序选择并运行更多线程），然后在指定的时间后恢复它。

在GO中，有time.sleep（time）方法，该方法已知是阻止方法。假设我有一千个GO例程（因为Go具有自己的线程调度程序，而不是依靠OS调度程序，这不是一个问题），我想实现重试模式在这些过程中的每一个中，以这样的方式：

FOR 5 Times {
   IF Request Fails 
      THEN
          time.Sleep(time.Second * 30)
   ELSE
      RETURN
}

在这种情况下，使用time.sleep（time）是安全的吗？还是有更好的方法？

编辑：我不是在问time.sleep（time）正在阻止！我不知道为什么我的问题是该帖子的重复！

原文

In C# when we want to cause delay between the execution of two procedures we have two options:

Thread.Sleep(time) which is blocking
await Task.Delay(time) which is non-blocking

In other words, Thread.Sleep(time) blocks the current thread for the specified time while await Task.Delay(time) suspends the executing
thread (allowing the OS thread scheduler to select and run more threads) and then it resumes it after the specified time.

In Go, there is time.Sleep(time) method which is known to be a blocking method. Being new to Go, I have this question, assuming I have a thousand of go routines (since go has it's own thread scheduler instead of relying on the OS scheduler, this should not be a problem) and I would like to implement a retry pattern in each one of these go routines in such a way that:

FOR 5 Times {
   IF Request Fails 
      THEN
          time.Sleep(time.Second * 30)
   ELSE
      RETURN
}

Would it be safe to use time.Sleep(time) in this case? Or is there a better way?

Edit:
I am not asking if time.Sleep(time) is blocking!! I have no I idea why my question is duplicate of that post!

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

软甜啾 2025-02-13 07:58:51

GO中没有异步/等待。要有一个非障碍睡眠，您必须将其包裹在goroutine中。然后，它可以使用频道消息将结果归还到主要上下文。

// create a channel to receive the return value of an asynchronous function
channel := make(chan bool)
// this is a goroutine which executes asynchronously
go func() {
    time.Sleep(5 * time.Second)
    // send a message to the channel
    channel <- true
}()
// setup a channel listener
select {
case val: <-channel:
    // Execute some code after a timeout, val contains the sent value
}

There's no async/await in go. To have a non-blocking sleep you have to wrap it in a goroutine. Then it can return its result to the main context using a channel message.

// create a channel to receive the return value of an asynchronous function
channel := make(chan bool)
// this is a goroutine which executes asynchronously
go func() {
    time.Sleep(5 * time.Second)
    // send a message to the channel
    channel <- true
}()
// setup a channel listener
select {
case val: <-channel:
    // Execute some code after a timeout, val contains the sent value
}

回复收藏 0 原文