golangで非同期にタスクを行ってリトライしてくれる君を作った

スポンサーリンク
プログラミング
スポンサーリンク

What

非同期でタスクを実行、追加できるようにするくん
自作ライブラリを作成した

Why

GCPのタスクキューを見て、非同期でタスクをポンポン投げて勝手に実行、リトライしてくれるようなものを作ってみたかった

リポジトリ

コードはこちらに
https://github.com/nozo-moto/taskqueue

使い方

// set task queue interval
taskQueue := taskqueue.New(100 * time.Millisecond)
defer taskQueue.Stop()
// Run Task Queue Job in background.
go taskQueue.Run()

// Add Task, you can set retry coun
// if taskQueue.Stop called taskQueue.Add return err
err := taskQueue.Add(
    func() error {
        fmt.Printf("hoge\n")
        return nil
    },
    5,
)

コメント

タイトルとURLをコピーしました