butcher

butcher

Overview

Butcher is a library providing a simple way to execute some task concurrency. Integrates convenient features such as concurrency control and retry.

Quick Start

package main

import (
    "context"
    "fmt"
    "github.com/KawashiroNitori/butcher"
)

type executor struct{}

func (e *executor) GenerateJob(ctx context.Context, jobCh chan<- interface{}) error {
    // generate your jobs here
    for i := 0; i < 100; i++ {
        // you can check canceled context or not, is up to you
        select {
        case <- ctx.Done():
            return nil
        default:
        }
        
        // push your job into channel
        jobCh <- i
    }
    // you may NOT close jobCh manually
    return nil
}

func (e *executor) Task(ctx context.Context, job interface{}) error {
    // execute your job here
    fmt.Printf("job %v finished!\n", job)
    return nil
}

// OnFinish implement an optional func to check your job is finished if you want
func (e *executor) OnFinish(ctx context.Context, job interface{}, err error) {
    if err != nil {
        fmt.Println("job %v error: %v", job, err)
    }
}

func main() {
    ctx := context.Background()
    b, err := butcher.NewButcher(&executor{})  // you can add some options here
    if err != nil {
        panic(err)
    }
    
    err = b.Run(ctx)
    if err != nil {
        panic(err)
    }
}