如何使用Golang实现命令队列模式

type Command interface {
    Execute()
}

type PrintCommand struct {
    Msg string
}
<p>func (p *PrintCommand) Execute() {
fmt.Println("打印消息:", p.Msg)
}</p><p>type SaveCommand struct {
Data string
}</p><p>func (s *SaveCommand) Execute() {
fmt.Println("保存数据:", s.Data)
}
</font></p><H3>创建命令队列和处理器</H3><p>使用channel作为任务队列，启动一个或多个goroutine来消费这些命令。</p>
                    <div class="aritcle_card">
                        <a class="aritcle_card_img" href="/ai/1358">
                            <img src="https://img.php.cn/upload/ai_manual/000/000/000/175680215970086.jpg" alt="Robovision AI">
                        </a>
                        <div class="aritcle_card_info">
                            <a href="/ai/1358">Robovision AI</a>
                            <p>一个强大的视觉AI管理平台</p>
                            <div class="">
                                <img src="/static/images/card_xiazai.png" alt="Robovision AI">
                                <span>65</span>
                            </div>
                        </div>
                        <a href="/ai/1358" class="aritcle_card_btn">
                            <span>查看详情</span>
                            <img src="/static/images/cardxiayige-3.png" alt="Robovision AI">
                        </a>
                    </div>
                <p>基本结构如下：</p><font face="Courier New"><pre class="brush:php;toolbar:false;">
type CommandQueue struct {
    commands chan Command
    workers  int
}
<p>func NewCommandQueue(workers int) *CommandQueue {
return &CommandQueue{
commands: make(chan Command, 100), // 缓冲队列
workers:  workers,
}
}</p><p>func (cq *CommandQueue) Start() {
for i := 0; i < cq.workers; i++ {
go func() {
for cmd := range cq.commands {
cmd.Execute()
}
}()
}
}</p><p>func (cq *CommandQueue) AddCommand(cmd Command) {
cq.commands <- cmd
}</p><p>func (cq *CommandQueue) Stop() {
close(cq.commands)
}
</font></p><H3>实际使用示例</H3><p>把上面的组件组合起来，可以这样使用：</p><font face="Courier New"><pre class="brush:php;toolbar:false;">
func main() {
    queue := NewCommandQueue(2) // 启动两个工作协程
    queue.Start()
<pre class='brush:php;toolbar:false;'>// 提交一些命令
queue.AddCommand(&PrintCommand{Msg: "Hello"})
queue.AddCommand(&SaveCommand{Data: "user123"})
queue.AddCommand(&PrintCommand{Msg: "World"})

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

queue.Stop()

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