平博彩票网博彩平台赌博_

[[443122]]

全球好，我是 polarisxu。

并发是 Go 的上风，但并发也需要很好的进行放胆。圭臬库中有 sync 包，常常使用的功能有 sync.Mutex、sync.WaitGroup 等。其实，除了圭臬库，还有一个官方的扩张库，也叫 sync，其中有一个子包：sync/singleflight，稀奇作念并披发胆，比如看重缓存击穿。

01 从例子提及

看一个模拟缓存的例子，有如下代码：

package 6868棋牌main  import (  "errors"  "flag"  "log"  "sync" )  var errorNotExist = errors.New("not exist")  var n int  func init() {  flag.IntVar(&n, "n", 5, "模拟的并发数，默许 5") }  func main() {  flag.Parse()   var wg sync.WaitGroup  wg.Add(n)   // 模拟并发拜谒  for i := 0; i < n; i++ {   go func() {    defer wg.Done()    // 假定齐获得 id = 1 这篇著作    article := fetchArticle(1)    log.Println(article)   }()  }  wg.Wait() }  type Article struct {  ID      int  Content string }   func fetchArticle(id int) *Article {  article := findArticleFromCache(id)   if article != nil && article.ID > 0 {   return article  }   return findArticleFromDB(id) }  var (  cache   = make(map[int]*Article)  rwmutex sync.RWMutex )  // 模拟从缓存获得数据 func findArticleFromCache(id int) *Article {  rwmutex.RLock()  defer rwmutex.RUnlock()  return cache[id] }  // 模拟从数据库中获得数据 func findArticleFromDB(id int) *Article {  log.Printf("SELECT * FROM article WHERE id=%d", id)  article := &Article{ID: id, Content: "polarisxu"}  rwmutex.Lock()  defer rwmutex.Unlock()  cache[id] = article  return article } 

咱们模拟 5 个用户并发拜谒，同期获得 ID=1 的著作，因为缓存中不存在，因此齐到后端 DB 获得具体数据。从运转恶果不错看出这少量：

皇冠客服飞机：@seo3687

$ go run main.go 2021/12/30 10:32:36 SELECT * FROM article WHERE id=1 2021/12/30 10:32:36 SELECT * FROM article WHERE id=1 2021/12/30 10:32:36 &{1 polarisxu} 2021/12/30 10:32:36 &{1 polarisxu} 2021/12/30 10:32:36 SELECT * FROM article WHERE id=1 2021/12/30 10:32:36 &{1 polarisxu} 2021/12/30 10:32:36 SELECT * FROM article WHERE id=1 2021/12/30 10:32:36 &{1 polarisxu} 2021/12/30 10:32:36 SELECT * FROM article WHERE id=1 2021/12/30 10:32:36 &{1 polarisxu} 

彰着这是咱们不但愿看到的。

02 使用 singleflight

官方的扩张包 golang.org/x/sync 底下有一个子包 singleflight：

Package singleflight provides a duplicate function call suppression mechanism. 

它用来防止函数的相通调用，这适值稳当上头的场景：但愿从数据库获得数据的函数只调用一次。

将 fetchArticle 函数改成这么：

var g singleflight.Group  func fetchArticle(id int) *Article {  article := findArticleFromCache(id)   if article != nil && article.ID > 0 {   return article  }   v, err, shared := g.Do(strconv.Itoa(id), func() (interface{}, error) {   return findArticleFromDB(id), nil  })    // 打印 shared，望望齐什么值  fmt.Println("shared===", shared)   if err != nil {   log.Println("singleflight do error:", err)   return nil  }   return v.(*Article) } 

singleflight.Group 是一个结构体类型，莫得导出任何字段，它代表一类责任并变成一个定名空间，在该定名空间中不错防止责任单位的相通现实。

该类型有三个标准，它们的功能见扎眼：

皇冠新网址

// 现实并复返给定函数的恶果，确保关于给定的键，fn 函数只会现实一次。 // 淌若有相通的进来，相通的调用者会恭候最原始的调用完成并收到接头的恶果。 // 复返值 shared 指导是否将 v 提供给多个调用者。 // 复返值 v 是 fn 的施作歹果 // 复返值 err 是 fn 复返的 err func (g *Group) Do(key string, fn func() (interface{}, error)) (v interface{}, err error, shared bool) // 和 Do 访佛，但复返一个 channel（只可汲取），用来汲取恶果。Result 是一个结构体，有三个字段，即 Do 复返的那三个。 func (g *Group) DoChan(key string, fn func() (interface{}, error)) <-chan Result func (g *Group) Forget(key string) 

因此，改后的代码，通过 Group.Do，即使并发屡次调用，findArticleFromDB 也只会现实一次，况兼这一次的恶果会被并发屡次现实分享。

运转后，恶果如下：

$ go run main.go 2021/12/30 11:55:44 SELECT * FROM article WHERE id=1 shared=== true 2021/12/30 11:55:44 &{1 polarisxu} shared=== true 2021/12/30 11:55:44 &{1 polarisxu} shared=== true 2021/12/30 11:55:44 &{1 polarisxu} shared=== true 2021/12/30 11:55:44 &{1 polarisxu} shared=== true 2021/12/30 11:55:44 &{1 polarisxu} 

和预期相通，findArticleFromDB 只现实了一次，shared 的值也示意恶果被多个调用者分享。

近期，NBA明星库里和他的妻子艾莉西亚公开了他们的家庭生活和成长故事，备受球迷们的瞩目和关注。想了解更多有关库里家庭的消息和八卦，欧博会员开户不妨加入皇冠体育博彩平台，与全球球迷一起分享和讨论。银河娱乐澳门

是以，使用 Go 后，再也不需要通过访佛 Redis 中的 SETNX 这么的敕令来完了访佛的功能了。

03 Forget 的用途

上头 Group 的标准中，有一个莫得给任何扎眼，即 Forget。从名字猜到，用来忘掉什么，那具体什么意旨风趣呢?

通过上头的例子，咱们明白，通过 Do，不错完了多个并发调用只现实回调函数一次，并分享接头的恶果。而 Forget 的作用是：

Forget tells the singleflight to forget about a key. Future calls to Do for this key will call the function rather than waiting for an earlier call to complete.

即告诉 singleflight 健忘一个 key，翌日对此 key 的 Do 调用将调用 fn 回调函数，而不是恭候更早的调用完成，即畸形于覆没 Do 本来的作用。

不错在上头例子中 Do 调用之前，调用 g.Forget，考据是否 Do 的调用齐现实 fn 函数即 findArticleFromDB 函数了。

彩票平台排行 04 泛型版块

注意的读者可能会发现，Do 标准复返的 v 是 interface{}，在 fetchArticle 函数终末，咱们作念了类型断言：v.(*Article)。

据赛事主办方介绍，邵阳站是今年中国桨板超级联赛首站，以“逐浪天子湖·争锋桨板赛”为主题，设公开组、大师组、卡胡纳组、高校组和青少年组5个组别。

既然 Go1.18 随即要来了，有了泛型，不错有泛型版块的 singleflight，不需要作念类型断言了。GitHub 也曾有东说念主完了并开源：https://github.com/marwan-at-work/singleflight。

博彩平台赌博

改成这个泛型版块，要改以下几处：

平博彩票网

皇冠hg86a

导入包 marwan.io/singleflight，而非 github.com/marwan-at-work/singleflight，同期移除 golang.org/x/sync/singleflight g 的声明改为：var g singleflight.Group[*Article] Do 的调用，复返值由 interface{} 类型改为：*Article：

article, err, shared := g.Do(strconv.Itoa(id), func() (*Article, error) {   return findArticleFromDB(id), nil }) 

终末复返时，告成复返 article，不需要作念类型断言 05 回顾

singleflight 很常用，你在 pkg.go.dev 搜索 singleflight，发现存好多轮子：https://pkg.go.dev/search?q=singleflight，好些名目不是使用官方的 golang.org/x/sync/singleflight，而是我方完了一个，不外这些完了基本只完了了最常用的 Do 标准。感意思的不错检察他们的完了。

 

下次名目中需要访佛功能，谨记使用 singleflight 哦!

皇冠体育维基百科