singleflight

Documentation

Index

• type Group
  • func (g *Group[T]) Do(key string, fn func() (T, error)) (v T, err error, shared bool)
  • func (g *Group[T]) DoChan(key string, fn func() (T, error)) <-chan Result[T]
  • func (g *Group[T]) Forget(key string)
• type Result

Types

type Group

type Group[T any] struct {
	// contains filtered or unexported fields
}

func (*Group[T]) Do

func (g *Group[T]) Do(key string, fn func() (T, error)) (v T, err error, shared bool)

Do 执行并返回给定函数的结果，确保一次只有一个给定键的执行正在进行中。 如果出现重复项，重复调用者将等待原始调用者完成并收到相同的结果。 返回值 shared 用于指示值 v 是否被提供给了多个调用方。

func (*Group[T]) DoChan

func (g *Group[T]) DoChan(key string, fn func() (T, error)) <-chan Result[T]

DoChan 类似于Do，但返回一个通道，当结果准备就绪时，该通道将接收结果。 返回的通道不会关闭。

func (*Group[T]) Forget

func (g *Group[T]) Forget(key string)

删除传入的key，这样后续调用此key时，请求不会阻塞。

type Result

type Result[T any] struct {
	Val    T
	Err    error
	Shared bool
}