triggered

package

v0.0.3 Latest Latest Go to latest Published: Aug 1, 2023 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type EventExecute[PARAMS any] struct {
	// contains filtered or unexported fields
}

EventExecute封装了一个执行单元包含执行函数,恢复函数和相关控制参数

func RegisterExecute[PARAMS any](execDo func(params *Params[PARAMS]), recoverDo func(ierr any)) *EventExecute[PARAMS]

RegisterExecute注册一个执行单元返回分配的事件号

func (exec *EventExecute[PARAMS]) Notify(params *PARAMS)

Notify用于通知触发执行根据事件号查找执行单元并检查通知次数达到指定次数则触发goroutine异步执行

func (e *EventExecute[PARAMS]) SetConcurrentNum(v int64)

func (e *EventExecute[PARAMS]) SetShared(v any)

type Params[T any] struct {
	Value  *T
	Shared *Shared
}

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

func (s *Shared) SetValue(v any)

func (s *Shared) Value(do func(v any))