Golang构建基础任务队列与处理系统-Golang-PHP中文网

Golang构建基础任务队列与处理系统

P粉602998670

发布： 2025-09-25 09:32:01

原创

841人浏览过

答案：使用Go的channel和Goroutine可构建高效任务队列。定义Task接口与具体任务，通过带缓冲channel实现任务队列，启动多个工作协程并发消费，支持灵活扩展与控制并发度。

golang构建基础任务队列与处理系统

在高并发场景下，任务队列是解耦耗时操作、提升系统响应速度的重要手段。Golang凭借其轻量级的Goroutine和高效的Channel机制，非常适合构建简单而高效的任务队列系统。下面介绍如何使用原生Go语言实现一个基础但实用的任务队列与处理系统。

定义任务结构与执行接口

每个任务应包含可执行的逻辑和必要的上下文数据。通过接口定义任务行为，提高扩展性。

type Task interface { Execute() }

type SimpleTask struct { ID int Name string }

func (t SimpleTask) Execute() { fmt.Printf("正在执行任务: %s (ID: %d)\n", t.Name, t.ID) time.Sleep(1 time.Second) // 模拟耗时操作 fmt.Printf("任务完成: %s\n", t.Name) }

构建任务队列与调度器

使用带缓冲的channel作为任务队列，配合多个工作协程并行消费任务。

type WorkerPool struct { tasks chan Task workers int }

func NewWorkerPool(taskQueueSize, workerCount int) *WorkerPool { return &WorkerPool{ tasks: make(chan Task, taskQueueSize), workers: workerCount, } }

func (wp *WorkerPool) Start() { for i := 0; i < wp.workers; i++ { go func(workerID int) { for task := range wp.tasks { fmt.Printf("工作协程 %d 开始处理任务\n", workerID) task.Execute() } }(i + 1) } }

func (wp *WorkerPool) AddTask(task Task) { wp.tasks <- task }

func (wp *WorkerPool) Stop() { close(wp.tasks) }

实际使用示例

创建任务池，提交多个任务，并观察并发执行效果。

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

Devv

Devv是一个专为程序员打造的新一代AI搜索引擎

140

查看详情

func main() { pool := NewWorkerPool(10, 3) // 队列容量10，3个工作协程 pool.Start()

// 提交一批任务
for i := 1; i <= 5; i++ {
    pool.AddTask(&SimpleTask{
        ID:   i,
        Name: fmt.Sprintf("任务-%d", i),
    })
}

// 等待任务执行（简单方式：休眠）
time.Sleep(6 * time.Second)
pool.Stop()

登录后复制

}

关键点说明：