执行心脏跳动函数

大家好，今天本人给大家带来文章《执行心脏跳动函数》，文中内容主要涉及到，如果你对Golang方面的知识点感兴趣，那就请各位朋友继续看下去吧~希望能真正帮到你们，谢谢！

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

我需要什么？ 我有一个 websocket，并且有一个 for {}，它不断读取消息，现在每 10 秒我需要调用一次心跳函数，而无需中断程序或停止读取聊天内容。 我正在考虑使用一些方法，但没有一种方法看起来干净/很好地使用渠道，但我认为更有经验的人可能有一个好的和更简单的方法。

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

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)

解决方案

编辑：接受@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 秒后终止。

您将希望能够关闭股票代码，因此请勿使用 time.tick ，而是使用 time.newticker。

如果将带有代码的整个 for 循环移动到 goroutine 中，它不会阻塞主 goroutine。

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

以上就是《执行心脏跳动函数》的详细内容，更多关于的资料请关注golang学习网公众号！