Pool of Workers

Package workers implements concurrent workers

Installation

To download the specific tagged release, run:

go get github.com/omotto/workers

Import it in your program as:

import "github.com/omotto/workers"

Usage

    // New pool of workers
    pool := New()

    // Define global context for running workers
	ctx, cancel := context.WithDeadline(context.Background(), time.Now().Add(10*time.Second))
	defer cancel()

    // Add workers
	if id, err = pool.AddWorker(true, func (string) int { return 0 }, "pepe"); err != nil {
		panic(err)
	}
    ...

    // Execute pool of workers
    if err = pool.Run(ctx); err == nil {
        // Get executed worker result
        if results, err := pool.GetResults(id); err == nil {
		    fmt.Println(results[0].(int))
        }
    }