xsync

Documentation

Index

• type SingleCall
  • func (s *SingleCall) Do(key string, fn func() (interface{}, error)) (interface{}, error)
• type WaitGroupWrapper
  • func (wg *WaitGroupWrapper) Wrap(cb func())

Types

type SingleCall

type SingleCall 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 (*SingleCall) Do

func (s *SingleCall) 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.

type WaitGroupWrapper

type WaitGroupWrapper struct {
	sync.WaitGroup
}

WaitGroupWrapper wrap wait group

func (*WaitGroupWrapper) Wrap

func (wg *WaitGroupWrapper) Wrap(cb func())

Wrap wrap func to wait group