解决Go通道死锁的方法

亲爱的编程学习爱好者，如果你点开了这篇文章，说明你对《解决Go通道死锁的方法》很感兴趣。本篇文章就来给大家详细解析一下，主要介绍一下，希望所有认真读完的童鞋们，都有实质性的提高。

我正在学习go编程语言，最近我遇到一个问题，我尝试了很多方法来运行我的代码，但我无法正确运行。我怎样才能改变我的程序来做到这一点？

package main

import (
    "fmt"
    "sync"
)

type Task struct {
    Id       int
    Callback chan int
}

func main() {
    var wg sync.WaitGroup
    subTask := make([]Task, 100)
    for i := 0; i < 100; i++ {
        go func(i int) {
            task := Task{
                Id:       i,
                Callback: make(chan int, 1),
            }
            task.Callback <- i
            subTask = append(subTask, task)
        }(i)
    }

    for _, v := range subTask {
        wg.Add(1)
        go func(v Task) {
            defer wg.Done()
            x := <-v.Callback
            fmt.Printf("%d ", x)
        }(v)
    }
    wg.Wait()
}

解决方案

subtask 上存在数据争用。任务初始化 goroutine 在不同步的情况下读写变量 subtask。

该程序的目的是创建并初始化一个包含 100 个 task 值的切片，但它创建一个包含 100 个零值 tasks 的切片，并附加 100 个以上已初始化的 tasks（忽略刚才提到的数据争用问题）。

通过将任务分配给切片元素来解决这两个问题：

for i := 0; i < 100; i++ {
    go func(i int) {
        task := task{
            id:       i,
            callback: make(chan int, 1),
        }
        task.callback <- i
        subtask[i] = task
    }(i)
}

subtask 元素上存在数据争用。无法保证任务初始化 goroutines 在主 goroutine 覆盖这些元素之前完成对元素的写入。通过使用等待组来协调初始化 goroutine 和主 goroutine 的完成来修复：

subTask := make([]Task, 100)
for i := 0; i < 100; i++ {
    wg.Add(1)
    go func(i int) {
        task := Task{
            Id:       i,
            Callback: make(chan int, 1),
        }
        task.Callback <- i
        subTask[i] = task
        wg.Done()
    }(i)
}
wg.Wait()

Run the code on the playground。

race detector 报告了上述两种数据竞争。

如果问题中的代码是实际代码，而不是用于提出问题的最小示例，则根本不需要 goroutine。

理论要掌握，实操不能落！以上关于《解决Go通道死锁的方法》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！