完全没用的例子

前端解释

原谅我的狗屎前端。怕大家看不懂，我还是解释一下前端各个部分什么意思。

1. 图中①的区域，是计划定义区，可以设置一些参数，表示谁多久往聊天室说一句什么话。第二个表单可以输入1-10的数字，表示每隔几秒说话。当然cron支持六位的crontab周期定义。

2. 图中②的区域，是执行任务状态区，每秒刷新一次

3. 图中3的区域，就是我们的聊天室啦。后台定时任务钩子函数会定时把消息推到channel中，如果websocket服务端收到消息就发送到浏览器

后端逻辑

1. 实现定时计划接口func Run() croner.JobRunReturn

type JobS struct {
    Duration int    `json:"duration"`
    Who      string `json:"who"`
    What     string `json:"what"`
}

func (j JobS) Run() croner.JobRunReturn {
return croner.JobRunReturn{
        Value: fmt.Sprintf("[%s] %s: %s", time.Now().Format(time.RFC850), j.Who, j.What),
    }
}

2. 初始化设置

var manager = croner.NewCronManager(croner.CronManagerConfig{
true, false, 0, 0,
})

3.  加上钩子函数，如果接收到任务执行结果，将结果传到ch channel

croner.OnJobReturn(func(runReturn *croner.JobRunReturnWithEid) {
say := runReturn.Value.(string)
    ch })

4. 每当接受到post请求，就创建一个任务

_, err = manager.Add(fmt.Sprintf("@every %ds", curJob.Duration), curJob, nil)

5. 轮询获区ch传过来的值，通过websocket传到前端

for {
    select {
case msg :=         conn.WriteMessage(websocket.TextMessage, []byte(msg))
default:
continue
    }
}

实现

详细的使用可以查看测试文件，

任务接口

任务只要实现run()函数就行啦。这样我就可以包装你这个函数

type JobRunReturn struct {
    Value interface{}
    Error error
}

type JobInf interface {
    Run() JobRunReturn
}

任务失败控制

Cron没有失败控制，通过包装run()函数来实现cron的job接口来增加一些逻辑。加上一个defer来恢复panic, 通过设置配置ignorePanic来控制是否忽略错误继续执行，还是发生错误就是STOP

    defer func() {
        j.TotalCount += 1
if err := recover(); err != nil {
            errString := fmt.Sprintf("WrappedJob-%d %s  execute fail. error is %s", j.Id, j.Name, err)
            println(errString)
            atomic.StoreUint32(&j.status, FAIL)
if !j.father.ignorePanic {
                j.father.DisActive(j.Id)
            }
            j.father.jobReturnsWithEid                 JobRunReturn{nil, JobRunError{errString}},
                j.Id,
            }
        }
return
    }()

单任务周期时间只执行一次

这个主要靠锁来实现，任务运行时就锁住，直到完成之后才释放

j.running.Lock()
defer j.running.Unlock()

任务状态变更

通过原子操作来变更任务状态

atomic.StoreUint32(&(j.status), RUNNING)
defer atomic.StoreUint32(&(j.status), IDLE)

最大任务数量

通过buffered channel来实现最大任务数量

permit = make(chan struct{}, c.PoolSize)
permit struct{}{}
defer func() { 

钩子

不断获取任务回传结果，然后遍历执行钩子函数

    go func(){
for {
            select {
case value :=                 jobReturnHooks.Run(&value)
case                 return
            }
        }
    }()

缺陷

超时停止，本来尝试做的，配置里面都预留了这个字段。结果发现有问题。这个貌似要修改croner的源码，我不想这么做，但又想不出其他实现方案，我毕竟刚使用golang编程。如果有读者碰到类似问题或者有想法留言提醒我呀

OnlyOne 单次执行的时候，下次执行的时间就无法预测了。这个时候把任务的Next设置为一个不可能的值，比如1970-0-0。但如果在周期内执行完了，下次执行时间就准了...这貌似没办法解决。我也不知道任务什么时候执行完。

学习强大的APScheduler, Quartz

版权申明：内容来源网络，版权归原创者所有。除非无法确认，我们都会标明作者及出处，如有侵权烦请告知，我们会立即删除并表示歉意。谢谢。

Golang语言社区

ID：Golangweb

 www.GolangWeb.com

游戏服务器架构丨分布式技术丨大数据丨游戏算法学习