barrier

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

type Comparable interface {
	~int | ~int8 | ~int16 | ~int32 | ~int64 | ~uint | uint8 | uint32 | uint64 | ~string | ~float32 | ~float64 | struct{}
}

type HookOption struct {
	Current TaskHook
	Prev    TaskHook
	After   TaskHook
	Params  []interface{}
}

type JobFunc func() interface{}

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

type Set interface {
	Add(interface{}) bool      //添加元素
	Remove(interface{}) bool   //删除元素
	Contains(interface{}) bool //判断是否包含元素

	Size() int             //返回集合大小
	Clear()                //清空集合
	Values() []interface{} //返回集合中所有元素的切片
	KeysStr() []string

	Union(other Set) Set      //返回另一个集合的并集
	Intersect(other Set) Set  //返回另一个集合的交集
	Difference(other Set) Set //返回另一个集合的差集
}

type SetT[T Comparable] interface {
	Add(T) bool      //添加元素
	Remove(T) bool   //删除元素
	Contains(T) bool //判断是否包含元素

	Size() int   //返回集合大小
	Clear()      //清空集合
	Values() []T //返回集合中所有元素的切片
	ValueList() []T

	Union(other SetT[T]) SetT[T]      //返回另一个集合的并集
	Intersect(other SetT[T]) SetT[T]  //返回另一个集合的交集
	Difference(other SetT[T]) SetT[T] //返回另一个集合的差集
}

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

type Slice[T Comparable] struct {
	// contains filtered or unexported fields
}

type Task struct {
	Drop        bool
	Duration    time.Duration
	Description string
}

type TaskHook func(...interface{})

type TopicInter interface {
	AddTopic(string, HookOption) *topicTask
	PrevHandle(string, HookOption) *topicTask
	AfterHandle(string, HookOption) *topicTask
	DoAll()
}