go 并发库 singleflight 中 shared 值为何始终为 true
在 singleflight.do 方法中,第三个参数 shared 是一个布尔值,指示是否共享结果。按照注释的描述,该值应指示 v 值是否被多个调用者共享。但是,用户遇到了一个问题,无论调用次数多少,shared 值始终返回 true。
为了探究这个问题,我们分析了代码:
package main import ( "fmt" "sync" "time" "golang.org/x/sync/singleflight" ) func main() { g := singleflight.group{} wg := sync.waitgroup{} for i := 0; i < 8; i++ { wg.add(1) go func(j int) { defer wg.done() val, err, shared := g.do("userid", querymysql) if err != nil { fmt.println(err) return } fmt.printf("index: %d, val: %d, shared: %t\n", j, val, shared) }(i) } wg.wait() } // 模拟数据库查询方法 func querymysql() (interface{}, error) { time.sleep(time.millisecond * 1) fmt.println("mysql query") return 1, nil }
从代码中可以看出,使用 singleflight.group 执行并发查询,向 mysql 查询用户 id。
根据 singleflight.do 方法的文档,第四个返回参数 shared 的含义是:
the return value shared indicates whether v was given to multiple callers.
这意味着 shared 参数指示 v 值是否被多个调用者共享。因此,对同一查询的多个并发调用应该得到相同的 v 值,并且 shared 应该为 true。
但是,在给定的示例中,无论调用次数,shared 始终为 true。这是因为单一飞行模型的设计使然。在单一飞行模型中,并发请求被合并为一个请求,并且只有第一个请求执行查询。因此,所有并发请求都将收到相同的 v 值,从而导致 shared 始终为 true。
以下代码段说明了这一点:
group.Do("query", func() (interface{}, error) { // 查询数据库 return queryDB() })
在这个代码块中,singleflight.do 方法将确保只有一个并发调用执行 querydb 函数,其余并发调用将收到相同的结果。因此,所有并发调用将共享相同的 v 值,导致 shared 始终为 true。
因此,给定示例中的 shared 始终为 true 的行为是符合预期的,并且是由 singleflight.do 方法的设计造成的。
以上就是## singleflight.Do 方法中的 shared 值为何始终为 true?的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号