singleflight

README

import (
    "sync"
    "sync/atomic"
    "time"

    "github.com/joshqu1985/fireman/pkg/singleflight"
)

// 使用示例
var g singleflight.Group

// 在一个时间段内只被调用一次
fn := func() (interface{}, error) {
    return db.find().where(), nil
}

v, err := g.Do("key", fn)
if err != nil {
    fmt.Println("Do error: %v", err)
}

https://github.com/golang/groupcache/tree/master/singleflight

Documentation

Overview

Package singleflight provides a duplicate function call suppression mechanism.

Index

• type Group
  • func (g *Group) Do(key string, fn func() (interface{}, error)) (interface{}, error)

Types

type Group

type Group struct {
	// contains filtered or unexported fields
}

Group represents a class of work and forms a namespace in which units of work can be executed with duplicate suppression.

func (*Group) Do

func (g *Group) Do(key string, fn func() (interface{}, error)) (interface{}, error)

Do executes and returns the results of the given function, making sure that only one execution is in-flight for a given key at a time. If a duplicate comes in, the duplicate caller waits for the original to complete and receives the same results.