快捷導(dǎo)航

基于Go語言簡單實(shí)現(xiàn)事件管理器

更新時(shí)間：2023年11月27日 09:24:43 作者：洛天楓

在編程中,事件管理器是一種常見的工具,用于通過通知來觸發(fā)操作,本文將介紹一個(gè)簡單的Go事件管理器的實(shí)現(xiàn),并通過異步改進(jìn)提高其性能,感興趣的可以了解下

在編程中，事件管理器是一種常見的工具，用于通過通知來觸發(fā)操作。在Go語言中，我們可以通過創(chuàng)建事件管理器和監(jiān)聽器來實(shí)現(xiàn)事件的處理。本文將介紹一個(gè)簡單的Go事件管理器的實(shí)現(xiàn)，并通過異步改進(jìn)提高其性能。

監(jiān)聽器

首先，我們需要?jiǎng)?chuàng)建一個(gè)監(jiān)聽器。在這個(gè)實(shí)現(xiàn)中，監(jiān)聽器只是一個(gè)接收事件參數(shù)的函數(shù)。

type Listener[T any] func(T)

事件管理器

事件管理器是一個(gè)用于管理事件和監(jiān)聽器的結(jié)構(gòu)。它具有兩個(gè)方法：Add和Run。Add方法用于將新的監(jiān)聽器附加到事件上，而Run方法用于執(zhí)行事件管理器。

type Manager[T any] interface {
	Add(n string, l Listener[T])
	Run()
}

抽象事件管理器

為了方便使用，我們可以創(chuàng)建一個(gè)抽象事件管理器，它實(shí)現(xiàn)了事件管理器接口的一部分通用邏輯。雖然Go語言并不是面向?qū)ο蟮?，但我們可以通過模擬來實(shí)現(xiàn)類似的效果。

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方法用于添加監(jiān)聽器和Invoke方法用于觸發(fā)指定事件的監(jiān)聽器。

具體事件管理器

下面是一個(gè)具體的事件管理器的示例實(shí)現(xiàn)：命令事件管理器。該管理器接收用戶從控制臺(tái)輸入的命令，并根據(jù)命令類型觸發(fā)相應(yīng)的事件。

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方法獲取用戶從控制臺(tái)輸入的命令，并解析命令參數(shù)。如果沒有命令或者命令參數(shù)，則觸發(fā)"no-command"事件；否則，觸發(fā)"any-command"事件和具體命令的事件。

添加監(jiān)聽器

讓我們向命令事件管理器添加一些監(jiān)聽器。

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()
}

在上面的示例中，程序只執(zhí)行一次，但你可以將其放在一個(gè)無限循環(huán)中以持續(xù)監(jiān)聽命令。