Golang命令队列实现教程详解

type Command interface {
    Execute()
}

type PrintCommand struct {
    Msg string
}
func (p *PrintCommand) Execute() {
fmt.Println("打印消息:", p.Msg)
}
type SaveCommand struct {
Data string
}
func (s *SaveCommand) Execute() {
fmt.Println("保存数据:", s.Data)
}

type CommandQueue struct {
    commands chan Command
    workers  int
}
func NewCommandQueue(workers int) *CommandQueue {
return &CommandQueue{
commands: make(chan Command, 100), // 缓冲队列
workers:  workers,
}
}
func (cq *CommandQueue) Start() {
for i := 0; i < cq.workers; i++ {
go func() {
for cmd := range cq.commands {
cmd.Execute()
}
}()
}
}
func (cq *CommandQueue) AddCommand(cmd Command) {
cq.commands <- cmd
}
func (cq *CommandQueue) Stop() {
close(cq.commands)
}

func main() {
    queue := NewCommandQueue(2) // 启动两个工作协程
    queue.Start()
// 提交一些命令
queue.AddCommand(&PrintCommand{Msg: "Hello"})
queue.AddCommand(&SaveCommand{Data: "user123"})
queue.AddCommand(&PrintCommand{Msg: "World"})

// 简单等待
time.Sleep(time.Second)

queue.Stop()
}

打印消息: Hello
保存数据: user123
打印消息: World