- GoroutineSingle - a fiber backed by a dedicated goroutine. Every job is executed by a goroutine.
- GoroutineMulti - a fiber backed by more goroutine. Each job is executed by a new goroutine.
- Channels callback is executed for each message received.
Golang job scheduling for humans. It is inspired by schedule.
1.Install
go get github.com/jiansoft/robin
2.Use examples
import (
"log"
"time"
"github.com/jiansoft/robin"
)
func main() {
//The method is going to execute only once after 2000 ms.
//指定的方法將在2000亳秒之後執行一次
robin.Delay(2000).Do(runCron, "a Delay 2000 ms")
minute := 11
second := 50
//It will execute once at 14:11:50 every Friday.
//每星期五在14:11:50時將執行一次
robin.EveryFriday().At(14, minute, second).Do(runCron, "Friday")
//It will execute once every N days at 14:11:50
//每 N 天在14:11:50時將執行一次
robin.Every(1).Days().At(14, minute, second).Do(runCron, "Days")
//It will execute once at 11 minutes and 50 seconds past every N hours.
//每過 N 小時在11分50秒時將執行一次
robin.Every(1).Hours().At(0, minute, second).Do(runCron, "Every 1 Hours")
//It will execute once at the 50th second of every N minutes.
//每過 N 分鐘在第50秒時將執行一次
robin.Every(1).Minutes().At(0, 0, second).Do(runCron, "Every 1 Minutes")
//Every N seconds is going to execute once
//每過 N 秒將執行一次
robin.Every(10).Seconds().Do(runCron, "Every 10 Seconds")
p1 := player{Nickname: "Player 1"}
p2 := player{Nickname: "Player 2"}
p3 := player{Nickname: "Player 3"}
p4 := player{Nickname: "Player 4"}
//Create a channel
//建立一個頻道
channel := robin.NewChannel()
//Four player subscribe the channel
//建立四個玩家訂閱頻道
channel.Subscribe(p1.eventFinalBossResurge)
channel.Subscribe(p2.eventFinalBossResurge)
p3Subscribe := channel.Subscribe(p3.eventFinalBossResurge)
p4Subscribe := channel.Subscribe(p4.eventFinalBossResurge)
//Publish a message to the channel and then the four subscribers of the channel will
//receives the message each that "The boss resurge first." .
//發布一則訊息到頻道中然後頻道中的四個訂閱者將會各自收到一則"魔王首次復活"的訊息
channel.Publish("The boss resurge first.")
//Unsubscribe p3 and p4 from the channel.
//取消第3位和第4位玩家在該頻道的訂閱
channel.Unsubscribe(p3Subscribe)
p4Subscribe.Unsubscribe()
//This time just p1 and p2 receives the message that "The boss resurge second.".
//這次發布的訊息將只有第1位與第2位玩家各自收到一則"魔王第二次復活"的訊息
channel.Publish("The boss resurge second.")
//Unsubscribe all subscribers from the channel
//取消頻道內的所有訂閱者
channel.Clear()
//The channel is empty so no one can receive the message
//頻道內沒有任何訂閱者，所以沒有玩家會收到"魔王第三次復活"的訊息
channel.Publish("The boss resurge third.")
}
func runCron(s string) {
log.Printf("I am %s CronTest %v\n", s, time.Now())
}
type player struct {
Nickname string
}
func (p player) eventFinalBossResurge(someBossInfo string) {
log.Printf("%s receive a message : %s", p.Nickname, someBossInfo)
}Copyright (c) 2017
Released under the MIT license:
