tevent.go

package tevent

import "reflect"

type EventFunc interface {}

type TEvent struct {
	EventList map[int][]EventFunc
}

func getArgs(args ...interface{}) []reflect.Value {
	var ma = make([]reflect.Value, len(args))
	for k, v := range args {
		ma[k] = reflect.ValueOf(v)
	}
	return ma
}

//某事件发生
//eid 事件id
//args 参数
func (this *TEvent) Happen(eid int, args ...interface{}) {
	fs,ok := this.EventList[eid]
	if len(fs) == 0||!ok {
		return
	}
	argvs := getArgs(args...)
	for _, f := range fs {
		go reflect.ValueOf(f).Call(argvs)
	}
}

//添加事件处理函数
//eid 事件id
//fh 事件处理函数
func (this *TEvent) AddEventHandler(eid int, fh EventFunc) {
	this.EventList[eid] = append(this.EventList[eid], fh)
}

//移除事件处理函数
//eid 事件id
//fh 事件处理函数
func (this *TEvent) ReMoveEventHandler(eid int, fh EventFunc) {
	fs,ok := this.EventList[eid]
	if len(fs) == 0||!ok {
		return
	}
	for i, f := range fs {
		if reflect.ValueOf(fh) == reflect.ValueOf(f) {
			this.EventList[eid] = append(fs[:i], fs[i+1:]...)
			break
		}
	}
}

//工厂函数，生成一个事件类
func NewEvent() (e *TEvent) {
	e = new(TEvent)
	e.EventList = make(map[int][]EventFunc)
	return
}