Worker

README

Worker

Worker, which uses sync.Cond instead of channels.

Installing:

go get -u github.com/rustatian/Worker

Sample of usage:

package main

import (
	"fmt"
	"github.com/rustatian/Worker"
	"io/ioutil"
	"net/http"
	"runtime"
)

func main() {
	// create a variable
	var w Worker.Work
	
	// example of sites to get info from in parallel
	sites := []string{"http://google.com", "http://amazon.com", "http://spiralscout.com", "http://0xdev.me"}

    // add this sites to worker
	for _, v := range sites {
		w.Add(v)
	}

    // Run the work in 10 goroutines (for example)
    // So, we know, that we working with strings, and we need to make type assertion
    // Each task will be handled by separate goroutine
	w.Run(10, func(item interface{}) {
		str := item.(string)

        // we also could add work during the process of running
		w.Add("http://")
		r, err := http.Get(str)
		if err != nil {
			fmt.Println(err)
			return
		}

		_, err = ioutil.ReadAll(r.Body)
		if err != nil {
			fmt.Println(err)
			return
		}
	})
}

Documentation

Index

• type Work
  • func (w *Work) Add(item any)
  • func (w *Work) Run(n int, f func(item any))

Types

type Work

type Work struct {
	// contains filtered or unexported fields
}

func (*Work) Add

func (w *Work) Add(item any)

Add adds a new item to the work queue

func (*Work) Run

func (w *Work) Run(n int, f func(item any))