
深入剖析Go并发库singleflight的共享结果机制
Go语言的singleflight包有效避免了对同一键的重复计算。本文将深入探讨singleflight.Do函数的第三个返回值shared,并澄清其并非表示计算过程是否共享的常见误解。
singleflight.Do函数的第三个参数shared是一个布尔值,它指示返回的val值是否被多个调用者共享,而非计算过程本身是否共享。 代码示例中,虽然启动了8个并发协程执行g.Do("userId", queryMysql),但由于queryMysql函数执行时间(1毫秒)远小于协程调度开销,导致所有协程几乎同时调用g.Do,并等待第一个协程完成queryMysql并获取结果。因此,singleflight将第一个协程的计算结果val共享给其余7个协程,shared自然返回true。
shared的真正含义在于:结果val是否被多个调用者共享。只有当一个调用者的协程执行queryMysql时,其他协程处于等待状态,且该val仅被该协程使用时,shared才会返回false。在示例中,queryMysql执行时间短且并发度高,所有协程几乎同时等待第一个协程,导致shared始终为true。 如果延长queryMysql的执行时间(例如,增加time.Sleep),则可能观察到shared为false的情况。这需要确保在第一个协程完成计算前,其他协程能够被调度并进入等待状态。










