Golang worker pool

This is an implementation of a "generic" worker pool. You can define pools to call a function with your own defined input argument.

Simple Example

func jobfunc(args interface{}) error {
    s := args.(string)
    fmt.Println(s)
}


pool := NewPool(100, nil, jobfunc)
pool.Start()
pool.Add("Hello workerpool")

Interface example

type Example struct {
    results chan float
}

type argument struct {
    a float
    b float
}

func (e *Example) Jobfunc(args interface{}) error {
    if ex, ok := args.(argument); !ok {
        return fmt.Errorf("Type is not mytype - instead got %s", reflect.TypeOf(args))
    }
    e.results <- ex.a / ex.b
}

e := Example{results: make(chan float, 100)}

pool := NewPool(100, os.Stdout, e.Jobfunc)
pool.Start()
pool.Add(argument{a:10, b:20})

fmt.Println(<-e.results)