golang-work_pool实例

package main

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

/*
	使用gorouitne和channel实现一个计算int64随机数各位数和的我程序
	1.开启一个goroutine循环生成int64类型的随机数，发送到jobChan
	2.开启24个goroutine从jobChan中取出随机数计算个位数的和，将结果发送到resultChan
	3.主goroutine从resultChan去除结果并打印到终端输出
*/

//job...
type job struct {
	value int64
}
//result...
type Result struct {
	job	*job
	sum int64
}

var jobChan = make(chan *job,100)
var resultChan = make(chan *Result,100)
var wg sync.WaitGroup

func zhoulin(zl chan<- *job){
	defer wg.Done()
	//循环生成int64类型的随机数，发送到jobChan
	for {
		x := rand.Int63()
		newJob := &job{
			value: x,
		}
		zl <- newJob
		time.Sleep(time.Millisecond*500)
	}	
}
 
func baodelu(zl <-chan *job,resultChan chan<- *Result){
	defer wg.Done()
	//开启24个goroutine从jobChan中取出随机数计算个位数的和，将结果发送到resultChan
	for{
		job :=<- zl
		sum := int64(0) //
		n := job.value
		for n >0{
			sum += n%10
			n = n/10
		}
		newResult := &Result{
			job: job,
			sum : sum,
		}
		resultChan <- newResult
	}
}

func main() {
	wg.Add(25)
	go zhoulin(jobChan)
	//开启24个goroutine执行baodelu
	for i := 0; i <24;i++ {
		go baodelu(jobChan,resultChan)
	}
	//主goroutine从resultChan去除结果并打印到终端输出
	for result := range resultChan{
		fmt.Printf("value:%d sum:%d\n", result.job.value, result.sum)
	}
	wg.Wait()
}