如何用Golang实现定时任务并发执行_Golang 定时任务并发实践

在Golang中实现定时任务并发执行需结合time.Ticker与goroutine，每个任务通过独立goroutine和ticker周期触发，互不阻塞；示例中startTask函数用ticker定期执行任务，main函数启动多个任务并保持主协程运行；为保证并发安全，共享资源访问需使用sync.Mutex等机制保护；动态管理任务可通过stopCh等channel控制ticker生命周期，实现任务的动态启停与频率调整。

在 Golang 中实现定时任务并发执行，关键在于结合 time.Ticker 或 time.Sleep 与 goroutine 的使用。通过合理设计，可以做到多个任务按固定周期独立运行，互不阻塞。

使用 time.Ticker 启动周期性任务

每个定时任务可以用一个独立的 goroutine 驱动，配合 time.NewTicker 实现周期触发。

func startTask(name string, interval time.Duration) {
    ticker := time.NewTicker(interval)
    defer ticker.Stop()
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">for range ticker.C {
    fmt.Printf("执行任务: %s, 时间: %s\n", name, time.Now().Format("15:04:05"))
    // 模拟任务处理耗时
    time.Sleep(1 * time.Second)
}

}

立即学习“go语言免费学习笔记（深入）”；

func main() { go startTask("任务A", 3time.Second) go startTask("任务B", 5time.Second)

// 主协程保持运行
select {}

}

立即学习“go语言免费学习笔记（深入）”；

这种方式让每个任务独立计时、并发执行，不会因某个任务耗时影响其他任务的调度节奏。

控制并发安全与资源竞争

当多个定时任务操作共享资源（如日志文件、数据库连接池），需注意并发安全。

• 使用 sync.Mutex 保护临界区
• 避免在定时任务中长时间持有锁
• 考虑用 channel 代替锁进行通信协调

例如写日志时加锁：

Clipfly

一站式AI视频生成和编辑平台，提供多种AI视频处理、AI图像处理工具。

129

查看详情

var logMutex sync.Mutex
<p>func safeLog(msg string) {
logMutex.Lock()
defer logMutex.Unlock()
fmt.Println(msg)
}</p>

动态管理定时任务

实际场景中可能需要添加、停止或调整任务频率。可通过 channel 控制 ticker 生命周期。

示例：可取消的任务

<pre class="brush:php;toolbar:false;">func startCancelableTask(name string, interval time.Duration, stopCh <-chan bool) {
    ticker := time.NewTicker(interval)
    defer ticker.Stop()
<pre class="brush:php;toolbar:false;"><code>for {
    select {
    case <-ticker.C:
        fmt.Printf("执行: %s, 时间: %s\n", name, time.Now().Format("15:04:05"))
    case <-stopCh:
        fmt.Printf("任务 %s 已停止\n", name)
        return
    }
}

}

立即学习“go语言免费学习笔记（深入）”；

// 使用方式 stopB := make(chan bool) go startCancelableTask("任务B", 5*time.Second, stopB)

// 某个时刻停止 time.AfterFunc(20*time.Second, func() { close(stopB) })

使用第三方库简化开发

对于复杂调度需求（如 cron 表达式），推荐使用成熟库：

• robfig/cron：支持标准 cron 语法
• gocron：链式 API，易于使用

以 cron 为例：

<pre class="brush:php;toolbar:false;">c := cron.New()
c.AddFunc("*/1 * * * *", func() { // 每分钟执行
    fmt.Println("Cron 任务触发")
})
c.Start()

基本上就这些。Golang 原生机制已足够支撑大多数定时并发场景，重点是理解 goroutine 生命周期和 channel 控制。简单任务用 ticker + goroutine，复杂调度再引入第三方库，结构清晰又不易出错。

以上就是如何用Golang实现定时任务并发执行_Golang 定时任务并发实践的详细内容，更多请关注php中文网其它相关文章！