JobQueue - 任务队列

JobQueue 提供任务队列功能。

特性

• 任务入队和出队
• 优先级支持
• 并发控制
• 任务重试

安装

go get github.com/go-zoox/jobqueue

快速开始

基本使用

package main

import (
    "fmt"
    "github.com/go-zoox/jobqueue"
)

func main() {
    queue := jobqueue.New(&jobqueue.Config{
        Workers: 5,
    })
    
    // 添加任务
    queue.Enqueue(jobqueue.Job{
        ID:   "job1",
        Data: map[string]interface{}{"name": "task1"},
        Handler: func(job jobqueue.Job) error {
            fmt.Printf("Processing job: %s\n", job.ID)
            return nil
        },
    })
    
    // 启动队列
    queue.Start()
    defer queue.Stop()
}

更多信息

• GitHub 仓库