coming

//coming 是一个原生的任务调度系统，目前给出了定时任务和计划任务的解决方案

已实现功能: 1.添加定时任务

2.构造顺序工作链

3.实现暂停/重启功能

4.可循环执行功能，已实现，需要手动

任务调度

package main

import (
    "fmt"
    "time"

    "github.com/alexanyang/coming"
)

func main() {
    task := coming.NewTask()
    task.Add(func(this *coming.Task, i int) error {
        fmt.Printf("%s 执行第一个任务，序号：%v \n", time.Now(), i)
        this.PushData(fmt.Sprintf("第一个任务结果，序号：%v", i))
        time.Sleep(2 * time.Second)
        return nil
    }).Add(func(this *coming.Task, i int) error {
        fmt.Printf("%s 执行第二个任务，序号：%v \n", time.Now(), i)
        this.PushData(fmt.Sprintf("第二个任务结果，序号：%v", i))
        time.Sleep(2 * time.Second)
        return nil
    }).Add(func(this *coming.Task, i int) error {
        fmt.Printf("%s 执行第三个任务，序号：%v \n", time.Now(), i)
        this.PushData(fmt.Sprintf("第三个任务结果，序号：%v", i))
        time.Sleep(2 * time.Second)
        return nil
    })
    // 检查操作是否成功
    if err := task.Error(); err != nil {
        fmt.Println(err)
        return
    }
    fmt.Printf("%s: 任务Start\n", time.Now())
    if err := task.Start(); err != nil {
        fmt.Println(err)
        return
    }
    fmt.Printf("%s: 任务数量：%v, and run\n", time.Now(), task.Len())
    if err := task.Run(); err != nil {
        fmt.Println(err)
        return
    }
    time.Sleep(1 * time.Second)
    fmt.Printf("%s: 暂停中\n", time.Now())
    task.Pause()

    go func() {
        time.Sleep(5 * time.Second)
        fmt.Printf("%s: resume\n", time.Now())
        task.Resume()
    }()
    //fmt.Println("stop")
    //task.Stop()
    //开始等待结束
    fmt.Printf("%s: main等待执行完成 \n", time.Now())
    task.WaitFinish()
    fmt.Printf("%s: main执行完成\n", time.Now())
    fmt.Println("获取结果回调:")
    call, _ := task.Call()
    if len(call) > 0 {
        for k, v := range call {
            fmt.Printf("结果 %v:%v \n", k, v)
        }
    }
    time.Sleep(2 * time.Second)
    fmt.Println("结果输出完成")
}

运行定时任务

func TestNewSchedule(t *testing.T) {
    //ANY 分别对应时分秒,hour,minute,second
    coming.NewDailySchedule(ANY, ANY, ANY,"每秒任务", func(t time.Time) {
            fmt.Printf("现在时间是%s,定时执行中\n", t)
        })  
    //延时关闭才能看到协程输出
    time.Sleep(5 * time.Second)
}