用golang實(shí)現(xiàn)一個(gè)定時(shí)器任務(wù)隊(duì)列實(shí)例

func main() { 
 input := make(chan interface{}) 
 //producer - produce the messages
 go func() {
  for i := 0; i < 5; i++ {
   input <- i
  }
  input <- "hello, world"
 }()
 
 t1 := time.NewTimer(time.Second * 5)
 t2 := time.NewTimer(time.Second * 10)
 
 for {
  select {
  //consumer - consume the messages
  case msg := <-input:
   fmt.Println(msg)
 
  case <-t1.C:
   println("5s timer")
   t1.Reset(time.Second * 5)
 
  case <-t2.C:
   println("10s timer")
   t2.Reset(time.Second * 10)
  }
 }
}

type Timer struct {
 C <-chan Time
 r runtimeTimer
}

type OnceCron struct {
 tasks []*Task   //任務(wù)的列隊(duì)
 add chan *Task  //當(dāng)遭遇到新任務(wù)的時(shí)候
 remove chan string  //當(dāng)遭遇到刪除任務(wù)的時(shí)候
 stop chan struct{}  //當(dāng)遇到停止信號的時(shí)候
 Logger *log.Logger  //日志 
}
type Job interface {
 Run()     //執(zhí)行接口
}
type Task struct {
  Job  Job   //要執(zhí)行的任務(wù) 
 Uuid string   //任務(wù)標(biāo)識,刪除時(shí)用
 RunTime int64   //執(zhí)行時(shí)間
 Spacing int64   //間隔時(shí)間
 EndTime int64   //結(jié)束時(shí)間
 Number int    //總共要次數(shù)
}

func (one *OnceCron) Start() {
 //初始化的時(shí)候加入一個(gè)一年的長定時(shí)器,間隔1小時(shí)執(zhí)行一次
 task := getTaskWithFuncSpacing(3600, time.Now().Add(time.Hour*24*365).Unix（） , func() {
 log.Println("It's a Hour timer!")
 }) //為了代碼格式markdown 里面有個(gè)括號我改成全角了
 one.tasks = append(one.tasks, task)
 go one.run() //協(xié)成執(zhí)行 防止主進(jìn)程被阻塞
}

func (one *OnceCron) run() {

 for {
    //第一步 獲取任務(wù)
 now := time.Now() //獲取到當(dāng)前時(shí)間
 task, key := one.GetTask() //獲取最近的一個(gè)任務(wù)的執(zhí)行時(shí)間
 i64 := task.RunTime - now.Unix() //任務(wù)執(zhí)行和當(dāng)前時(shí)間的差

 var d time.Duration
 if i64 < 0 { //如果任務(wù)時(shí)間已過期,將執(zhí)行時(shí)間改成現(xiàn)在并且利馬執(zhí)行
 one.tasks[key].RunTime = now.Unix() 
 one.doAndReset(key)
      continue
 } else { //否則，獲取距離執(zhí)行開始的間隔時(shí)間
 d = time.Unix(task.RunTime, 0).Sub(now)
 }
    //第二步 產(chǎn)生定時(shí)器
 timer := time.NewTimer(d) 

 //第三步 捕獲定時(shí)器或者其他事件
 for {
 select { 
      //當(dāng)定時(shí)器到了執(zhí)行時(shí)間時(shí)，執(zhí)行當(dāng)前任務(wù)并關(guān)閉定時(shí)器
 case <-timer.C:
 one.doAndReset(key)
 if task != nil {
  go task.Job.Run()
  timer.Stop()
 }

 //當(dāng)外部添加了任務(wù)時(shí)，關(guān)閉當(dāng)前定時(shí)器
 case <-one.add:
 timer.Stop()
 //當(dāng)外部要?jiǎng)h除一個(gè)任務(wù)時(shí)，刪除ID為uuidstr的任務(wù)
 case uuidstr := <-one.remove:
 one.removeTask(uuidstr)
 timer.Stop()
 //當(dāng)遇到要關(guān)閉整個(gè)定時(shí)器任務(wù)時(shí)
 case <-one.stop:
 timer.Stop()
 return
 }

 break
 }
 }
}