Go worker pool. Just toying with ideas.

worker-pool.go

package main

import (
	"fmt"
	"math/rand"
	"time"
)

type StringsWorker struct {
	Errors chan<- error
	Input  chan string
	Output chan string
}

func (sw StringsWorker) Run() {
	for s := range sw.Input {
		switch s {
		case "foo":
			time.Sleep(time.Millisecond * time.Duration(rand.Intn(900)+100))
			sw.Output <- "bar"
		case "bar":
			time.Sleep(time.Millisecond * time.Duration(rand.Intn(900)+100))
			sw.Output <- "foo"
		case "close":
			sw.Output <- "ok"
			return
		}
	}
}

type WorkerPool struct {
	Errors  chan error
	Input   chan string
	Output  chan string
	Workers []StringsWorker
}

func NewWorkerPool(n int) WorkerPool {
	pool := WorkerPool{
		Errors:  make(chan error, 1),
		Input:   make(chan string),
		Output:  make(chan string),
		Workers: make([]StringsWorker, n),
	}
	for i := range pool.Workers {
		pool.Workers[i] = StringsWorker{
			Errors: pool.Errors,
			Input:  make(chan string),
			Output: make(chan string),
		}
	}
	return pool
}

func (pool WorkerPool) Run() {
	for _, worker := range pool.Workers {
		go worker.Run()
	}

	go func() {
		for s := range pool.Input {
		}		
	}()
}

func main() {
	rand.Seed(time.Now().Unix())
	fmt.Println("Hello, playground")
}