# work

**Repository Path**: mirrors_ContinuumLLC/work

## Basic Information

- **Project Name**: work
- **Description**: Implements a dynamic work pool of goroutines to perform tasks.
- **Primary Language**: Unknown
- **License**: MIT
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2021-07-14
- **Last Updated**: 2026-03-21

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# Work

Copyright 2014 Ardan Studios. All rights reserved.  
Use of this source code is governed by a MIT license that can be found in the LICENSE handle.

Package work uses an unbuffered channel to create a pool of goroutines that can perform work. Stats are maintained on the number of pending and active requests in the pool. Goroutines can be added and removed from the pool during pool operation. This allows for the implementation of a control port to adjust the size of the pool for maximum performance.

Ardan Studios  
12973 SW 112 ST, Suite 153  
Miami, FL 33186  
bill@ardanstudios.com

[Click To View Documentation](http://godoc.org/github.com/goinggo/work)

Sample App

	// This sample program demostrates how to use the work package
	// to use a pool of goroutines to get work done.
	package main

	import (
		"fmt"
		"log"
		"sync"
		"time"

		"github.com/goinggo/work"
	)

	// names provides a set of names to display.
	var names = []string{
		"steve",
		"bob",
		"mary",
		"therese",
		"jason",
	}

	// namePrinter provides special support for printing names.
	type namePrinter struct {
		name string
	}

	// Work implements the Worker interface.
	func (m *namePrinter) Work(id int) {
		fmt.Println(m.name)
		time.Sleep(time.Second)
	}

	func logFunc(message string) {
		log.Println(message)
	}

	// main is the entry point for all Go programs.
	func main() {
		// Create a work value with 2 goroutines.
		w, err := work.New(2, time.Second, logFunc)
		if err != nil {
			log.Fatalln(err)
		}

		var wg sync.WaitGroup
		wg.Add(10 * len(names))

		for i := 0; i < 10; i++ {
			// Iterate over the slice of names.
			for _, name := range names {
				// Create a namePrinter and provide the
				// specfic name.
				np := namePrinter{
					name: name,
				}

				go func() {
					// Submit the task to be worked on. When Run
					// returns we know it is being handled.
					w.Run(&np)
					wg.Done()
				}()
			}
		}

		for {
			// Enter a number and hit enter to change the size
			// of the work pool.
			var c int
			fmt.Scanf("%d", &c)
			if c == 0 {
				break
			}

			w.Add(c)
		}

		wg.Wait()

		// Shutdown the work and wait for all existing work
		// to be completed.
		w.Shutdown()
	}