使用协程启动多个服务

在尝试使用协程同时启动多个服务时，开发人员遇到了死锁错误。问题源于忘记在协程完成时调用 sync.WaitGroup 的 Done() 方法。修正后，协程可以正确完成，而主协程不再无限期等待，从而避免了死锁。

尝试总体熟悉子例程和 go，我正在尝试编写一个脚本，该脚本基本上将使用 sync.waitgroup 启动我的 django 应用程序的所有服务，并保持它们运行，直到我手动终止 go 脚本，这就是为什么我没有 intitialize() 函数实际上告诉等待组进程已完成。收到可怕的 fatal 错误：所有 goroutine 都在睡眠 - 死锁！ 消息。

func main() {
    var wg sync.WaitGroup
    os.Chdir("/home/Projects/djangoapp")
    cc := []cmds{cmds{
        name:  "django",
        cmdsl: []string{"/home/Projects/djangoapp/env/bin/python", "manage.py", "runserver"},
    },
        cmds{
            name:  "celeryd",
            cmdsl: []string{"/home/Projects/djangoapp/env/bin/celery", "-A", "djangoapp", "worker", "-l", "INFO", "-S", "django"},
        },
    }

    for x := 0; x < 2; x++ {
        wg.Add(1)
        fmt.Println("starting up", cc[x].name)
        go initialize(cc[x])
    }
    wg.Wait()
}

func initialize(ccmds cmds) {
    cmd := exec.Command(ccmds.cmdsl[0], ccmds.cmdsl[1:]...)
    cmd.Env = append(os.Environ(), "DJANGO_SETTINGS_MODULE=articleadmin.settings.default")

    fmt.Println("initializing", ccmds.name)
    cmd.Start()
    fmt.Println("started", ccmds.name)
    cmd.Wait()
}

它启动了服务，但随后因死锁错误而崩溃。我做错了什么？

解决方案

看起来你忘记在 goroutine 完成时调用 wg.done ：

go initialize(&wg,cc[x])
...

func initialize(wg *sync.WaitGroup,ccmds cmds) {
  defer wg.Done()
  ...
}

否则，wg.wait 将无限期等待。当所有 goroutine 终止时，main goroutine 将是唯一在该 waitgroup 上等待的 goroutine，因此会发生死锁。

理论要掌握，实操不能落！以上关于《使用协程启动多个服务》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！