| | |
| | | "bufio" |
| | | "bytes" |
| | | "flag" |
| | | "fmt" |
| | | "github.com/golang/protobuf/proto" |
| | | "gocv.io/x/gocv" |
| | | "image" |
| | |
| | | msg, err = c.Recv() |
| | | if err != nil { |
| | | logger.Info("recv error : ", err) |
| | | fmt.Println("recv error : ", err) |
| | | continue |
| | | } else { |
| | | arg := ruleserver.SdkDatas{} |
| | |
| | | package ruleserver |
| | | |
| | | import ( |
| | | "fmt" |
| | | "ruleprocess/logger" |
| | | "time" |
| | | ) |
| | |
| | | |
| | | func TimeTicker() { |
| | | logger.Info("定时器执行了") |
| | | fmt.Println("定时器执行了") |
| | | ticker := time.NewTicker(1 * time.Second) |
| | | go func(ticker *time.Ticker) { |
| | | defer ticker.Stop() |
| | |
| | | select { |
| | | case <-ticker.C: |
| | | logger.Info("定时器执行单元") |
| | | fmt.Println("定时器执行单元") |
| | | // 每秒钟计数器池子里所有的计数器元素都减一,减到0的是该报警的 |
| | | for _, timeEle := range TimeEleList { |
| | | if timeEle.N > 0 { |