channel误用导致的一个BUG

在协议处理时，在正规处理流程之外想利用channel来做一个类似listener的机制，就是发现如果有listener就把协议数据发给它；而listener可以临时监听自己感兴趣的任意协议并触发相应事件。代码流程大致如下：

chdata := make(chan []byte)

// 协议处理主流程

func process(data []byte) {

defer func() {

// 如果有listener就把协议数据发给它

select { case chdata <- data: default: }

}() // 根据协议号做分发处理 switch data[0] { // ... }

}

// 某个逻辑处理函数

func foo() {

ch := make(chan bool) go func() {

select { case data := <-chdata:

// 等待某个协议 if data[0] == 100 {

ch <- true

}

}

}() <-ch // 后续处理...

}

但是实际发现经常明明协议已经收到了，可就是监听不到导致foo函数死锁或者超时。根本的原因在于当foo函数从chdata获取一个协议进行检查发现不是自己感兴趣的协议时，它所感兴趣的协议已经到达process函数，而这时foo实际上已经不是select的状态，所以process函数认为没有listener在channel上等待数据因而执行default分支，从而导致协议漏掉。