golang：支持每周或者每天固定时间的事件触发器

Posted 2022-11-29 IGuoSJ

package main

/*
Author: Guo
Function: 支持每周或者每天固定时间的事件触发器
*/

import (
	"fmt"
	"time"
)

//一天的秒数
const oneDaySecond = 1 * 24 * 60 * 60

//定时器服务
func tickerService(stop chan int) 
	var ticker *time.Ticker
	var duration int64
	var isWeekBak bool
	for 
		now := time.Now()
		// 判断是否是每周六定时，不是的话就是每天固定时间定时
		if isWeekBak && now.Weekday() != time.Sunday 
			//当从每周定时切换到每日定时时，需要清除停止信号，因为可能周定时Ticker并没有创建，也就是说定时任务没有开始
			if len(stop) == 1 
				//fmt.Println("Clean Stop Chan")
				//fmt.Println("Clean Stop Chan Before: ", len(stop))
				<-stop
				//fmt.Println("Clean Stop Chan After: ", len(stop), " Num:", num, " time:", time.Now().Second())
			
			time.Sleep(time.Second * 30)
			fmt.Println("Not This Day.")
			continue
		
		//_, _, second := now.Clock()
		hour, minute, second := now.Clock()
		//当前时间
		//nowTime := time.Date(2020, 7, 18, 22, 25, second, 0, time.Local).Unix()
		nowTime := time.Date(2020, 7, 18, hour, minute, second, 0, time.Local).Unix()
		//每天的定时时间：22:25:30
		//setTime := time.Date(2020, 7, 18, 22, 25, 30, 0, time.Local).Unix()
		setTime := time.Date(2020, 7, 18, 22, 25, 30, 0, time.Local).Unix()
		minusTime := setTime - nowTime
		switch 
		case minusTime == 0:
			duration = oneDaySecond
		case minusTime > 0:
			duration = minusTime
		case minusTime < 0:
			duration = oneDaySecond + minusTime
		
		ticker = time.NewTicker(time.Second * time.Duration(duration))
		select 
		//监听停止定时信号
		case <-stop:
			fmt.Println("Timer Been Shutdown.")
			//停止之前的定时器
			ticker.Stop()
			//模拟定时器切换
			isWeekBak = true
			break
		case <-ticker.C:
			fmt.Printf("Guo Bak Time Is Up. Time: %s\\n", time.Now().Format("2006-01-02 15:04:05"))
			//TODO doSomeThing()
		
	


func main() 
	var stopChan = make(chan int, 1)
	go func() 
		for 
			select 
			case <-time.Tick(time.Second * 10):
				//清除之前的停止信号，因为可能不存在消费者，导致阻塞
				if len(stopChan) != 0 
					<-stopChan
					//fmt.Println("Output: ", len(stopChan), " time:", time.Now().Second())
				
				//发出停止信号，模拟定时的“改变事件”
				stopChan <- 100
				//fmt.Println("Input: ", len(stopChan), " time:", time.Now().Second())
				fmt.Printf("Guo Stop Time Is Up. Time: %s\\n", time.Now().Format("2006-01-02 15:04:05"))
			
		
	()
	go tickerService(stopChan)
	for
		time.Sleep(time.Second * 1000)