Go语言goroutine场景下如何实现channel无阻塞读取
问题1解答
你的判断是错误的,err := <- c 语句一定会阻塞worker协程。
带缓冲的channel只有在「读操作执行时缓冲区内已有可读取数据」的情况下才不会阻塞,你当前的代码执行逻辑是:
- worker创建容量为1的缓冲channel
- worker启动helper协程
- worker立刻执行读channel操作,此时helper协程大概率还没执行到
c <- err的写入步骤,channel缓冲区为空,读操作会一直阻塞,直到helper完成写入。
缓冲channel的非阻塞特性是双向的:写操作仅在缓冲区未满时不阻塞,读操作仅在缓冲区有数据时不阻塞,二者互不影响。
问题2解答
要实现无阻塞读取,不需要等待helper返回就继续执行worker的剩余逻辑,可以根据你对错误的处理需求选择以下两种方案:
方案1:完全不需要处理helper的错误
直接删除读channel的代码即可,因为你用的是容量为1的缓冲channel,helper执行完写入操作后不会出现协程泄漏,channel后续会被GC自动回收:
func worker() error { //do some work c := make(chan error, 1) go helper(c) // 直接继续执行剩余任务,不需要读channel // 此处写worker剩余逻辑 return nil // 这里的返回值根据你自己的业务逻辑调整即可 }
方案2:需要处理helper的错误,但不想阻塞当前执行逻辑
非阻塞读实现(适合worker后续某一阶段才需要判断错误的场景):
func worker() error { //do some work c := make(chan error, 1) go helper(c) // 非阻塞读,有错误就取,没错误直接走default继续执行 var err error select { case err = <-c: // 此时可以立即处理错误,也可以存起来后续处理 default: // 没有可读的错误,直接跳过不阻塞 } // 继续执行worker剩余任务 // ... 剩余逻辑 return err }
注意:单次非阻塞读只能拿到执行读操作那一刻channel里已有的错误,如果helper在你执行读操作之后才写完错误,这次读操作是拿不到的。如果需要确保捕获到helper的所有错误,优先选择下面的异步协程处理方案。
异步错误处理实现(适合不需要把错误返回给worker调用方,只需要内部处理的场景):
func worker() error { //do some work c := make(chan error, 1) go helper(c) // 启动单独协程处理错误,不阻塞当前worker go func() { err := <-c if err != nil { // 异步处理错误,比如打日志、上报监控等 } }() // 直接继续执行worker剩余任务 // ... 剩余逻辑 return nil }
内容的提问来源于stack exchange,提问作者Someone
相关产品推荐
相关产品推荐

