syncx

type Mutex ¶

type Mutex struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New(safe ...bool) *Mutex

func (mu *Mutex) IsSafe() bool

func (mu *Mutex) Lock()

func (mu *Mutex) Unlock()

type ResourceManager ¶

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

A ResourceManager is a manager that used to manage resources.

func NewResourceManager() *ResourceManager

func (manager *ResourceManager) Close() error

func (manager *ResourceManager) GetResource(key string, create func() (io.Closer, error)) (io.Closer, error)

func (manager *ResourceManager) Inject(key string, resource io.Closer)

type SingleFlight ¶

type SingleFlight interface {
	Do(key string, fn func() (interface{}, error)) (interface{}, error)
	DoEx(key string, fn func() (interface{}, error)) (interface{}, bool, error)
}

SingleFlight lets the concurrent calls with the same key to share the call result. For example, A called F, before it's done, B called F. Then B would not execute F, and shared the result returned by F which called by A. The calls with the same key are dependent, concurrent calls share the returned values. A ------->calls F with key<------------------->returns val B --------------------->calls F with key------>returns val

func NewSingleFlight() SingleFlight