go 的 map 本身不支持并发读写，即使仅读取也需加锁；若遍历时可能删除元素，必须使用 sync.rwmutex 的 rlock 保护，或改用更符合 go 风格的 channel + goroutine agent 模式。
go 的 map 本身不支持并发读写，即使仅读取也需加锁；若遍历时可能删除元素，必须使用 sync.rwmutex 的 rlock 保护，或改用更符合 go 风格的 channel + goroutine agent 模式。
在 Go 中，map 不是并发安全的——这是官方明确强调的设计约束（见 Go FAQ: atomic_maps）。虽然自 Go 1.9 起，多个 goroutine 同时只读 map 是安全的（因底层哈希表结构未被修改），但一旦存在任何写操作（如 delete、赋值新增），就必须进行同步控制。而你的 notifyAll 场景恰恰属于“读中带写”：遍历 self.connections 时，子 goroutine 可能调用 removeConn 触发 delete，此时若未加锁，将触发 panic：fatal error: concurrent map read and map write。
因此，直接 range 而不加锁是不安全的，哪怕你只在子 goroutine 中删除——因为 range 本身是读操作，而 removeConn 是写操作，二者发生在不同 goroutine，构成竞态。
✅ 正确做法一：使用 sync.RWMutex 加读锁
func (s *Server) notifyAll(event *Event) {
s.mu.RLock()
// 注意：必须在启动所有 goroutine 前完成复制或锁定，避免遍历中途 map 被修改
conns := make(map[int]*Conn)
for k, v := range s.connections {
conns[k] = v
}
s.mu.RUnlock() // 尽早释放读锁，提升并发性
ch := make(chan struct{}, 64)
for k, conn := range conns {
ch <p>⚠️ 关键注意点：</p><div class="aritcle_card flexRow artxards">
<div class="artcardd flexRow">
<a class="aritcle_card_img" rel="nofollow" href="/ai/772" title="BetterYeah AI"><img
src="https://img.php.cn/upload/ai_manual/000/000/000/175679972834149.png" alt="BetterYeah AI" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
<div class="aritcle_card_info flexColumn">
<a rel="nofollow" href="/ai/772" title="BetterYeah AI" class="overflowclass">BetterYeah AI</a>
<p class="overflowclass">BetterYeah AI是一款面向企业的一站式 AI Agent 应用开发平台。</p>
</div>
<a rel="nofollow" href="/ai/772" title="BetterYeah AI" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
</a>
</div>
</div>
- RLock() 必须覆盖整个 range 过程，不能只锁住 range 语句本身——因为 range 是迭代器行为，若在迭代中途 removeConn 修改 map，仍可能崩溃；
- 更稳妥的做法是：*先加 RLock，将当前 map 快照复制到局部变量（如 `map[int]Conn），再RUnlock`，最后遍历副本**。这样既避免长时间持锁，又彻底消除读写冲突。
✅ 正确做法二：Go 风格的 channel agent 模式（推荐用于复杂生命周期管理）
如答案中所示，通过专用 goroutine 统一处理所有 map 变更，完全规避并发访问：
type Server struct {
connections map[int]*Conn
addChan chan addReq
removeChan chan int
notifyChan chan *Event
}
type addReq struct {
conn *Conn
key int
}
func (s *Server) agent() {
for {
select {
case req := <p>该模式优势明显：</p>
- 零锁设计：所有 map 操作均在单一 goroutine 中串行执行；
- 职责清晰：读（notify）、写（add/remove）解耦，天然避免竞态；
- 可扩展性强：便于加入连接超时、批量清理、日志审计等逻辑。
总结
| 场景 | 推荐方案 | 说明 |
|---|---|---|
| 简单服务、低频变更 | sync.RWMutex + 快照复制 | 实现简单，性能足够，需严格遵循“读锁→复制→解锁→遍历”流程 |
| 高并发、长生命周期连接管理 | channel agent 模式 | 更符合 Go 的 CSP 哲学，长期维护性与安全性更优 |
切记：永远不要假设 map 在多 goroutine 下“只读就安全”——只要存在任何写操作，就必须协调访问。 选择哪种方案，取决于你的系统规模、可维护性要求及团队对并发模型的熟悉程度。
