将 goroutine 放入上下文中的方法是什么？

本篇文章给大家分享《将 goroutine 放入上下文中的方法是什么？》，覆盖了Golang的常见基础知识，其实一个语言的全部知识点一篇文章是不可能说完的，但希望通过这些问题，让读者对自己的掌握程度有一定的认识(B 数)，从而弥补自己的不足，更好的掌握它。

我正在开发一个 go 项目，需要在单独的 goroutine 中调用启动函数 (initfunction)（以确保此函数不会干扰项目的其余部分）。 initfunction 不得超过 30 秒，所以我想我会使用 context.withtimeout。最后，initfunction 必须能够向调用者通知错误，因此我想到创建一个错误通道并从匿名函数调用 initfunction 来接收并报告错误。

func RunInitGoRoutine(initFunction func(config string)error) error {

    initErr := make(chan error)
    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Seconds)

    go func() {
        <-ctx.Done()  // Line 7
        err := initFunction(config)
        initErr <-err
    }()

    select {
    case res := <-initErr:
        return res.err
    case <-ctx.Done():
        err := errors.New("Deadline")
    return err
    }
}

我对 go 还很陌生，所以我寻求有关上述代码的反馈。

1. 我对第 7 行有一些疑问。我用它来确保匿名函数“包含”在 ctx 下，因此在超时到期后被杀死并释放，但我不确定我是否做了正确的事情。
2. 第二件事是，我知道我应该在某个地方调用 cancel( )，但我无法确定在哪里。
3. 最后，我们欢迎任何反馈，无论是关于效率、风格、正确性还是其他方面的反馈。

正确答案

在 go 中，实践是通过通道进行通信。因此，最好的办法可能是在您的上下文中共享一个频道，以便其他人可以从该频道进行消费。

正如您所说，您是 go 新手，我写了一大堆关于 go（入门级）的文章 https://marcofranssen.nl/categories/golang。

从旧到新阅读以熟悉该语言。

有关渠道的具体信息，您应该看看这篇文章。

https://marcofranssen.nl/concurrency-in-go

本博文中描述了一个 web 服务器侦听 ctrl+c 然后使用通道正常关闭服务器的实际示例。

https://marcofranssen.nl/improved-graceful-shutdown-webserver

本质上，我们在后台例程中运行服务器

go func() {
    if err := srv.listenandserve(); err != nil && err != http.errserverclosed {
      srv.l.fatal("could not listen on", zap.string("addr", srv.addr), zap.error(err))
    }
  }()

然后我们有一些代码通过侦听通道上的关闭信号来阻止主例程。

quit := make(chan os.signal, 1)

  signal.notify(quit, os.interrupt)
  sig := <-quit
  srv.l.info("server is shutting down", zap.string("reason", sig.string()))

  ctx, cancel := context.withtimeout(context.background(), 30*time.second)
  defer cancel()

  srv.setkeepalivesenabled(false)
  if err := srv.shutdown(ctx); err != nil {
    srv.l.fatal("could not gracefully shutdown the server", zap.error(err))
  }
  srv.l.info("server stopped")

这与您的用例非常相似。因此，在后台例程中运行您的 init，然后使用等待此 init 例程结果的通道。

package main

import (
    "fmt"
    "time"
)

type InitResult struct {
    Message string
}

func main() {
    initResult := make(chan InitResult, 0)
    go func(c chan<- InitResult) {
        time.Sleep(5 * time.Second)
        // here we are publishing the result on the channel
        c <- InitResult{Message: "Initialization succeeded"}
    }(initResult)

    fmt.Println("Started initializing")

    // here we have a blocking operation consuming the channel
    res := <-initResult

    fmt.Printf("Init result: %s", res.Message)
}

https://play.golang.org/p/_YGIrdNVZx6

您还可以在结构上添加一个错误字段，以便您可以按照通常的方式进行错误检查。

终于介绍完啦！小伙伴们，这篇关于《将 goroutine 放入上下文中的方法是什么？》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！