Golang代码为何产生死锁？如何按id动态懒初始化channel队列？

• 你给出的代码死锁的核心原因是goroutine的调度顺序不确定：主goroutine大概率会先执行到<-m[0]，此时子goroutine还未完成m[0]的初始化，m[0]的值为nil channel。根据Go语言规范，从nil channel接收数据会永久阻塞，主goroutine卡在此处无法继续执行，最终触发死锁。
• 额外存在并发安全隐患：Go的map原生不支持并发读写，你在子goroutine中写入map、主goroutine中读取map的操作没有同步机制，即使调度顺序刚好子goroutine先执行完成，也存在数据竞争风险，严重时会直接触发运行时panic。

你需要的按id懒加载独立队列的需求，可以通过加读写锁+双重检查的逻辑实现，既保证并发安全，又不需要预先初始化所有id对应的channel，实现代码如下：

package main

import (
	"fmt"
	"sync"
)

// DynamicChanManager 动态channel管理器，封装了懒加载逻辑和并发安全控制
type DynamicChanManager struct {
	mu    sync.RWMutex
	chans map[int]chan string
}

func NewDynamicChanManager() *DynamicChanManager {
	return &DynamicChanManager{
		chans: make(map[int]chan string),
	}
}

// GetChan 获取指定id对应的channel，不存在则自动初始化
func (d *DynamicChanManager) GetChan(id int) chan string {
	// 先加读锁检查是否已存在，大部分命中场景下性能更高
	d.mu.RLock()
	ch, ok := d.chans[id]
	d.mu.RUnlock()
	if ok {
		return ch
	}

	// 不存在则加写锁初始化
	d.mu.Lock()
	defer d.mu.Unlock()
	// 双重检查：避免加锁过程中其他goroutine已经完成了该id的初始化
	ch, ok = d.chans[id]
	if !ok {
		// 缓冲区大小可根据业务需求调整，无缓冲也可正常使用
		ch = make(chan string, 1)
		d.chans[id] = ch
	}
	return ch
}

func main() {
	manager := NewDynamicChanManager()
	targetId := 0

	go func() {
		ch := manager.GetChan(targetId)
		ch <- "abab"
	}()

	ch := manager.GetChan(targetId)
	fmt.Println(<-ch)
}

方案说明 #

• 所有对map的读写操作都通过读写锁同步，彻底解决并发访问的安全问题，不会出现数据竞争
• 只有第一次访问某个id的channel时才会创建对应实例，完全符合懒加载要求，内存开销极低
• 双重检查逻辑保证了高并发场景下的性能：绝大多数请求只需要加读锁即可拿到channel，只有首次创建新channel时才会触发写锁，性能损耗极小
• 扩展说明：如果业务中存在id生命周期结束的场景，可以额外添加回收方法，加锁删除map中对应的key并关闭channel，避免内存泄漏

内容的提问来源于stack exchange，提问作者GinGin3203