如何实现作业的并行运行？

积累知识，胜过积蓄金银！毕竟在Golang开发的过程中，会遇到各种各样的问题，往往都是一些细节知识点还没有掌握好而导致的，因此基础知识点的积累是很重要的。下面本文《如何实现作业的并行运行？》，就带大家讲解一下知识点，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

当我收到一个通道时，有时我得到的通道值是相同的，这样gocron就会做同样的工作。有办法解决这个问题吗？

package main

import (
    "fmt"
    "strings"
    "time"

    "github.com/go-co-op/gocron"
)

func main() {
    for {
        channel := make(chan string)
        go func() {
            channel <- "19:59"
            channel <- "19:59"
            channel <- "19:59"

        }()

        for data := range channel {
            s := gocron.NewScheduler(time.Now().Location())
            dd := strings.Split(data, ",")

            for i, dt := range dd {
                fmt.Println(dt, i)
                s.Every(1).Day().At(dt).SingletonMode().Do(task)

            }
            s.StartAsync()
        }
    }

}

func task() {
    fmt.Println("RUNNNNNNN")
}

正确答案

使用 map 来跟踪相同的时间戳是否已被处理。

func main() {
    records := make(map[string]struct{}) // a tracking records

    for {
        channel := make(chan string)
        go func() {
            channel <- "19:59"
            channel <- "19:59"
            channel <- "19:59"
        }()

        for data := range channel {
            // check for existence
            if _, ok := records[data]; !ok {
                records[data] = struct{}{} // add this record

                s := gocron.NewScheduler(time.Now().Location())
                dd := strings.Split(data, ",")

                for i, dt := range dd {
                    fmt.Println(dt, i)
                    s.Every(1).Day().At(dt).SingletonMode().Do(task)
                }
                s.StartAsync()
            }
        }
    }
}

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《如何实现作业的并行运行？》文章吧，也可关注golang学习网公众号了解相关技术文章。