十二. Go並發編程--sync/errGroup

  • 2021 年 12 月 12 日
  • 筆記

一.序 这一篇算是并发编程的一个补充,起因是当前有个项目,大概の 需求是,根据kafka的分区(partition)数,创建同等数量的 消费者( goroutine )从不同的分区中消费者消费数据,但是总有某种原因导致,某一个分区消费者创建失败,但是其他分区消费者创建失败。 最初的逻辑是,忽略分区失 …

Continue Reading

八. Go並發編程--errGroup

  • 2021 年 11 月 8 日
  • 筆記

一. 前言 了解 sync.WaitGroup 的用法都知道 一个 goroutine 需要等待多个 goroutine 完成和多个 goroutine 等待一个 goroutine 干活时都可以解决问题 WaitGroup 的确是一个很强大的工具,但是使用它相对来说还是有一点小麻烦, 一方面我们需 …

Continue Reading