文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

Go事件管理器:简单实现

2024-11-30 04:27

关注

监听器

首先,我们需要创建一个监听器。在这个实现中,监听器只是一个接收事件参数的函数。

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 string
 Args []string
}

type CommandEventManager struct {
 BaseManager[*Command]
}

func (m *CommandEventManager) Run() {
 var (
  inp  string
  args 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", a+b)
 })

 cem.Run()
}

在上面的示例中,程序只执行一次,但你可以将其放在一个无限循环中以持续监听命令。

异步改进

可以将事件管理器的执行改为异步方式,以提高性能。每次执行事件时,可以将其作为一个goroutine进行处理。甚至可以将每个监听器的执行也放在一个goroutine中,以提高并发性能。

通过上述改进,我们可以更好地利用Go语言的并发特性,提高事件处理效率。

来源:爱发白日梦的后端内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯