evn

type Config struct {
	Size int // 处理事件的任务数量
	Capy int // 每个任务的通道能力

} //

type Event struct {
	Id TEventID

} //

type EventDo struct {
	Id  TEventID
	Fun func()

} //

type IContrler interface {
	ctl.IControler

	// 监听事件(eventId重复则进行覆盖)
	Listen(event IEvent, handle TEventHandler)

	// 投递事件(sync:此时间是否需要被同步有序处理)
	Post(event IEvent, sync ...bool)

	// 投递事件并自动监听(sync:此时间是否需要被同步有序处理)
	PostDo(event IEventDo, sync ...bool)
}

type IEvent interface {
	EventId() TEventID
}

type IEventDo interface {
	IEvent
	Do()
}

type TEventHandler func(IEvent)

type TEventID = string

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

type TaskHandFunc func(param interface{}) (ret interface{}, err error)

type TaskHandler interface {
	OnHandleTask(param interface{}) (ret interface{}, err error)
}