如何运行心跳功能

Question

我看到了大量关于如何定期运行函数的问题。 问题？他们都锁定程序无法继续运行。

我需要什么？ 我有一个 websocket，我有一个 for {}，它一直在读取 msg，现在每 10 秒我需要运行一次对 heartbeat 函数的调用，而不会中断程序或停止阅读聊天。 我正在考虑使用一些方法，但使用渠道似乎都不干净/不错，但我认为更有经验的人可能对此有更好更简单的方法。

我正在使用类似的东西，但它永远不会到达函数的末尾以返回程序继续运行所需的内容。

timerCh := time.Tick(time.Duration(10) * time.Second)
  for range timerCh {
    go Heartbeat(ws)
}

return ws

我正在寻找一种能够每 10 秒调用一次 Heartbeat 的方法：

1. 每次读取传入的 websocket 连接时都会重复调用它
2. 不锁定程序。

一些上下文， 这是一个桥接聊天，所以我打开一个 websocket，继续阅读这个，只有在聊天消息时才发送到另一个聊天，同时我需要发送一个心跳而不锁定这个。 我现在有什么？ 现在一切正常，但大约 30 秒后我的 websocket 关闭：

2020/07/01 20:59:09 Error read: websocket: close 1000 (normal)

Answer 1

编辑：选择@JimB 的答案！这只是为了表明应该在main goroutine 之外管理计时器。

您的心跳函数应该管理自己的计时器。像这样的东西应该可以工作：

package main

import (
    "fmt"
    "time"
)

func main() {
    go heartbeat()
    for i := 0; i < 10; i++ {
        fmt.Println("main is still going")
        time.Sleep(time.Second * 3)
    }
}

func heartbeat() {
    for {
        timer := time.After(time.Second * 10)
        <-timer
        fmt.Println("heartbeat happened!")
    }
}

此示例将每 3 秒从main 打印一次，每10 从心跳打印一次，并将在 30 秒后终止。

Answer 2

您希望能够关闭自动收报机，因此不要使用time.Tick，而是使用time.NewTicker。

如果你把整个for循环和ticker一起移动到一个goroutine中，它不会阻塞主goroutine。

go func() {
    ticker := time.NewTicker(10 * time.Second)
    defer ticker.Stop()
    for range ticker.C {
        Heartbeat(ws)
        // return on error or cancellation
    }
}()