package task

/*
  @Author : lanyulei
*/

import (
	"gitee.com/wuzheng0709/backend-gopkg/infrastructure/pkg/gin/log"
	"gitee.com/wuzheng0709/backend-gopkg/infrastructure/pkg/task/worker"
)

func Start() {
	// 1. 启动服务，连接redis
	worker.StartServer()

	// 2. 启动异步调度
	taskWorker := worker.NewAsyncTaskWorker(10)
	err := taskWorker.Launch()
	if err != nil {
		log.Error("启动machinery失败，%v", err.Error())
	}
}