async

package
v1.6.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 18, 2025 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

Package async 提供一个简单的异步 / 定时任务封装: 1. 使用 cron 支持定时任务(cmd: scheduler) 2. 简单封装 goroutine 以支持异步任务

Index

Constants

This section is empty.

Variables

View Source
var RegisteredTasks = map[string]any{
	"CalcFib": task.CalcFib,
}

RegisteredTasks 已注册的任务 注意:任务函数最后一个返回值推荐为 error 类型

Functions

func ApplyTask

func ApplyTask(ctx context.Context, name string, args []any)

ApplyTask 下发异步任务

func InitTaskScheduler

func InitTaskScheduler(ctx context.Context)

InitTaskScheduler 初始化任务调度器

Types

type TaskScheduler

type TaskScheduler struct {
	// contains filtered or unexported fields
}

TaskScheduler 简单的定时任务调度器,依赖 robfig/cron & model.PeriodicTask

func Scheduler

func Scheduler() *TaskScheduler

Scheduler 获取调度器

func (*TaskScheduler) LoadTasks

func (s *TaskScheduler) LoadTasks() error

LoadTasks 加载所有周期任务

func (*TaskScheduler) Run

func (s *TaskScheduler) Run()

Run 启用调度器

Directories

Path Synopsis
Package task 包含异步任务实现
Package task 包含异步任务实现

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL