登录
首页 >  Golang >  Go教程

Golang命令模式任务调度详解

时间:2025-12-04 12:32:34 389浏览 收藏

各位小伙伴们,大家好呀!看看今天我又给各位带来了什么文章?本文标题《Golang Command模式任务调度教程》,很明显是关于Golang的文章哈哈哈,其中内容主要会涉及到等等,如果能帮到你,觉得很不错的话,欢迎各位多多点评和分享!

命令模式通过封装请求实现任务调度,Go中定义Command接口与具体命令,结合Scheduler定时执行,解耦任务注册与执行逻辑,支持灵活扩展。

Golang Command命令模式任务调度示例

在Go语言中,命令模式(Command Pattern)是一种行为设计模式,它将请求封装为对象,从而使你可以用不同的请求、队列或日志来参数化其他对象。结合任务调度系统,命令模式可以很好地实现任务的注册、执行与管理。

命令模式核心结构

命令模式通常包含以下几个部分:

  • Command接口:定义执行操作的方法,如Execute()
  • 具体命令:实现Command接口,持有接收者并调用其方法
  • Receiver:真正执行任务的对象
  • Invoker:调用命令的对象,比如调度器
  • Client:创建命令并绑定接收者

基本命令接口与任务实现

我们先定义一个通用的Command接口,并实现几个具体任务:

package main

import ( "fmt""time" )

// Command 接口type Command interface { Execute() }

// 打印消息的接收者type PrintReceiver struct { Message string }

func (p *PrintReceiver) Print() { fmt.Println("打印:", p.Message, " | 时间:", time.Now().Format("15:04:05")) }

// 发送邮件命令type SendEmailCommand struct { Receiver *PrintReceiver }

func (c *SendEmailCommand) Execute() { c.Receiver.Message = "发送用户通知邮件" c.Receiver.Print() }

// 备份数据库命令type BackupDBCommand struct { Receiver *PrintReceiver }

func (c *BackupDBCommand) Execute() { c.Receiver.Message = "正在备份数据库" c.Receiver.Print() }

任务调度器实现

接下来我们构建一个简单的调度器,支持定时执行注册的命令:

type Scheduler struct {
    commands []Command
    interval time.Duration
}

func NewScheduler(interval time.Duration) *Scheduler { return &Scheduler{ commands: make([]Command, 0), interval: interval, } }

func (s *Scheduler) AddCommand(cmd Command) { s.commands = append(s.commands, cmd) }

func (s *Scheduler) Start() { ticker := time.NewTicker(s.interval) go func() { for range ticker.C { for _, cmd := range s.commands { cmd.Execute() } } }() }

使用示例

最后是主函数中的调度使用方式:

func main() {
    receiver := &PrintReceiver{}
scheduler := NewScheduler(3 * time.Second)
scheduler.AddCommand(&SendEmailCommand{Receiver: receiver})
scheduler.AddCommand(&BackupDBCommand{Receiver: receiver})

fmt.Println("任务调度已启动...")
scheduler.Start()

// 防止主程序退出
select{}

}

运行结果会每隔3秒依次输出:

打印: 发送用户通知邮件 | 时间: 10:30:01
打印: 正在备份数据库 | 时间: 10:30:01

这个例子展示了如何使用命令模式解耦任务定义与执行逻辑,同时通过调度器统一管理多个任务的周期性执行。你可以扩展支持延迟执行、任务取消、错误重试等功能。

基本上就这些,结构清晰且易于维护。

好了,本文到此结束,带大家了解了《Golang命令模式任务调度详解》,希望本文对你有所帮助!关注golang学习网公众号,给大家分享更多Golang知识!

相关阅读
更多>
最新阅读
更多>
课程推荐
更多>