创建网站域名,网赢做网站怎么样,易购网网页设计素材,怀孕单子图片在线制作关注公众号【爱发白日梦的后端】分享技术干货、读书笔记、开源项目、实战经验、高效开发工具等#xff0c;您的关注将是我的更新动力#xff01; 在编程中#xff0c;事件管理器是一种常见的工具#xff0c;用于通过通知来触发操作。在Go语言中#xff0c;我们可以通过创建… 关注公众号【爱发白日梦的后端】分享技术干货、读书笔记、开源项目、实战经验、高效开发工具等您的关注将是我的更新动力 在编程中事件管理器是一种常见的工具用于通过通知来触发操作。在Go语言中我们可以通过创建事件管理器和监听器来实现事件的处理。本文将介绍一个简单的Go事件管理器的实现并通过异步改进提高其性能。
监听器
首先我们需要创建一个监听器。在这个实现中监听器只是一个接收事件参数的函数。
type Listener[T any] func(T)事件管理器
事件管理器是一个用于管理事件和监听器的结构。它具有两个方法Add和Run。Add方法用于将新的监听器附加到事件上而Run方法用于执行事件管理器。
type Manager[T any] interface {Add(n string, l Listener[T])Run()
}抽象事件管理器
为了方便使用我们可以创建一个抽象事件管理器它实现了事件管理器接口的一部分通用逻辑。虽然Go语言并不是面向对象的但我们可以通过模拟来实现类似的效果。
type BaseManager[T any] struct {lst map[string][]Listener[T]
}func (m *BaseManager[T]) Invoke(n string, args T) {for _, ls : range m.lst[n] {ls(args)}
}func (m *BaseManager[T]) Add(n string, l Listener[T]) {m.lst[n] append(m.lst[n], l)
}BaseManager提供了Add方法用于添加监听器和Invoke方法用于触发指定事件的监听器。
具体事件管理器
下面是一个具体的事件管理器的示例实现命令事件管理器。该管理器接收用户从控制台输入的命令并根据命令类型触发相应的事件。
type Command struct {Kind stringArgs []string
}type CommandEventManager struct {BaseManager[*Command]
}func (m *CommandEventManager) Run() {var (inp stringargs Command)fmt.Scanln(inp)cmd : strings.Split(inp, :)if l : len(cmd); l 0 {m.Invoke(no-command, nil)} else if l 1 {args.Args strings.Split(cmd[1], )}args.Kind cmd[0]m.Invoke(any-command, args)m.Invoke(args.Kind, args)
}func NewCommandEventManager() Manager[*Command] {return CommandEventManager{BaseManager: BaseManager[*Command]{lst: make(map[string][]Listener[*Command])},}
}Run方法获取用户从控制台输入的命令并解析命令参数。如果没有命令或者命令参数则触发no-command事件否则触发any-command事件和具体命令的事件。
添加监听器
让我们向命令事件管理器添加一些监听器。
func main() {cem : NewCommandEventManager()cem.Add(no-command, func(_ *Command) {fmt.Println(no command was recieved)})cem.Add(any-command, func(c *Command) {fmt.Printf(the %s command was executed, c.Kind)})cem.Add(sum, func(c *Command) {a, _ : strconv.Atoi(c.Args[0])b, _ : strconv.Atoi(c.Args[1])fmt.Printf(the sum result is: %d, ab)})cem.Run()
}在上面的示例中程序只执行一次但你可以将其放在一个无限循环中以持续监听命令。
异步改进
可以将事件管理器的执行改为异步方式以提高性能。每次执行事件时可以将其作为一个goroutine进行处理。甚至可以将每个监听器的执行也放在一个goroutine中以提高并发性能。
通过上述改进我们可以更好地利用Go语言的并发特性提高事件处理效率。
