答案：Golang通过channel和Goroutine可实现高效任务队列，核心包括任务、队列、工作者与调度器。使用带缓冲channel存放任务，启动多个worker从队列消费，支持优先级可通过Task结构体扩展，结合heap实现优先调度；生产环境需添加错误处理与回调机制，确保任务状态可追踪。该方案轻量灵活，适用于多数异步场景，关键在于控制并发与缓冲大小，避免资源泄漏。
任务队列在高并发系统中非常常见，用于解耦耗时操作、削峰填谷、异步处理等场景。Golang 凭借其轻量级的 Goroutine 和强大的 Channel 机制，非常适合实现高效的任务队列。下面介绍一种简单但实用的 Golang 任务队列实现方式。
基本结构设计
一个基础的任务队列通常包含以下几个部分：
- 任务（Task）：表示需要执行的具体工作，一般封装为函数或结构体。
- 任务队列（Queue）：用于存放待处理任务的缓冲区，可用 channel 实现。
- 工作者（Worker）：从队列中取出任务并执行，通常以 Goroutine 形式运行。
- 调度器（Dispatcher）：管理多个工作者，分发任务。
使用 Channel 实现无缓冲任务队列
最简单的实现是使用无缓冲 channel 配合固定数量的 worker。
func main() {taskCh := make(chan func(), 100) // 带缓冲的任务队列
workerCount := 5
// 启动 workers
for i := 0; i go func() {
for task := range taskCh {
task()
}
}()
}
// 提交任务
for i := 0; i num := i
taskCh fmt.Printf("处理任务: %d\n", num)
time.Sleep(time.Second)
}
}
close(ta
skCh) // 关闭通道，通知所有 worker 结束time.Sleep(2 * time.Second) // 等待执行完成
}
这种方式适合任务量不大、无需持久化的场景。channel 的容量决定了队列长度，超出会阻塞提交。
支持优先级和类型的任务结构体设计
如果任务有不同类型或优先级，可以定义结构体来封装任务信息。
type Task struct {Priority int
Handler func()
}
// 使用优先队列（需配合 heap 包）或按 priority 分多个 channel
更进一步，可以结合 Go 的 container/heap 实现优先级队列，由 dispatcher 按优先级出队并派发。
添加错误处理与任务状态回调
生产环境中，任务执行可能失败，需要记录日志或重试。可以在 Task 中加入回调函数。
type Task struct {Name string
Handler func() error
OnSuccess func()
OnFail func(err error)
}
Worker 执行完后根据返回值调用对应回调，便于监控和追踪。
基本上就这些。通过 channel + goroutine 可快速构建一个轻量级任务队列。对于需要持久化、分布式、延时任务等高级功能，可考虑集成 Redis（如使用 machiko 或 asynq 库），但在多数内部服务中，原生实现已足够灵活高效。关键是控制并发数、避免 Goroutine 泄漏，并合理设置队列缓冲大小。不复杂但容易忽略。
