如何定期安排任务？

Question

是否有任何本地库或第三方支持，例如 ScheduledExecutorService by java native library at go lang for production 用例？

请在 java 1.8 中找到代码片段：

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;


public class TaskScheduler {

    /**
     * @param args
     */
    public static void main(String[] args) {
        Runnable runnable = ()-> {
                // task to run goes here
                System.out.println("Hello !!");
        };
        ScheduledExecutorService service = Executors.newScheduledThreadPool(1);
        service.scheduleAtFixedRate(runnable, 0, 1, TimeUnit.SECONDS);

    }

}

它会每隔一秒打印一次Hello !!。

Answer 1

无需使用第 3 方库即可实现。只需利用 goroutine 并使用 time 包中可用的 time.Sleep() API，即可获得相同的结果。

示例：

go func() {
    for true {
        fmt.Println("Hello !!")
        time.Sleep(1 * time.Second)
    }
}()

游乐场：https://play.golang.org/p/IMV_IAt-VQX

使用代码#1 的示例

根据 Siddhanta 的建议。这是一个使用 ticker 实现相同结果的示例（取自 go documentation page of ticker，根据您的要求进行一些修改）。

done := make(chan bool)
ticker := time.NewTicker(1 * time.Second)

go func() {
    for {
        select {
        case <-done:
            ticker.Stop()
            return
        case <-ticker.C:
            fmt.Println("Hello !!")
        }
    }
}()

// wait for 10 seconds
time.Sleep(10 *time.Second)
done <- true

ticker时间信息（Hello !!执行的时间）可以从ticker.C频道获取。

case t := <-ticker.C:
    fmt.Println(t)

游乐场：https://play.golang.org/p/TN2M-AMr39L

使用代码 #2 的示例

另一个简化的自动收报机示例，摘自https://gobyexample.com/tickers

ticker := time.NewTicker(1 * time.Second)
go func() {
    for range ticker.C {
        fmt.Println("Hello !!")
    }
}()

// wait for 10 seconds
time.Sleep(10 *time.Second)
ticker.Stop()

如何定期安排任务？

How to schedule a task at go periodically?

scheduler

scheduled-tasks

go

使用代码#1 的示例

使用代码 #2 的示例