package main

import (
	"context"
	"errors"
	"fmt"
	bytask "gitee.com/neuro-netw0rk/server-golib/async_task"
	"time"
)

func main() {
	scheduler, _ := bytask.NewScheduler("127.0.0.1:6379", 100, 9)

	// 注册处理器
	scheduler.RegisterHandler("report", func(ctx context.Context, task *bytask.Task) error {
		time.Sleep(time.Second * 5)
		fmt.Printf("Generating report: %+v\n", task.Payload)
		return errors.New("report error")
	})

	// 启动服务
	err := scheduler.Start()
	if err != nil {
		return
	}
}