golang队列任务处理

package main

import (
	"crypto/rand"
	"fmt"
	"math/big"
	"strconv"
	"strings"
	"time"
)

type task struct {
	id       uint32   // 订单编号
	callback chan int // 工厂编号
}

const taskNum = 16                          // 准备找16个工厂
var chTaskList = make([]chan task, taskNum) // 工厂列表

var arr = [10]int{0, 1, 2, 3, 4, 5, 6, 7, 8, 9}

func task_init() {
	for i := 0; i < taskNum; i++ {
		chTaskList[i] = make(chan task)            // 工厂登记
		go working(chTaskList[i], i) // 工厂开门大吉，待命中
	}
}

func main() {
	task_init() // 工厂就绪
	time.Sleep(1 * time.Second)

	for i := 0; i < 100; i++ {
		go order() // 给工厂派活
	}
	time.Sleep(5 * time.Second)
}

// 出任务的，甲方爸爸
func order() {
	id := randomString(10)                       // 来个订单号
	callack := make(chan int)                    // 把返程的招呼打好
	t := task{id: uint32(id), callback: callack} // 订单起草完毕

	chTasks := chTaskList[id%taskNum] // 随机选择一个工厂,因为id都是随机生成的，取余数也是一个随机值
	chTasks <- t                      // 把订单交给小弟让他送工厂去

	msg := <-callack
	fmt.Printf("给%v号工厂下了订单，%v号工厂拿到了订单\n", id%taskNum, msg)
}

// 工厂，接收小弟(chan)，返回工厂编号
func working(chTasks chan task, num int) {
	fmt.Printf("第%v号工厂待命中...\n", num)
	for {
		t := <-chTasks    // 卸货
		id := t.id        // 订单编号
		_ = id            // 此处生产产品（业务逻辑）
		t.callback <- num // 返回工厂编号
	}
}

// 生成订单号
func randomString(n int) uint32 {
	var b []string
	for i := 0; i < n; i++ {
		num, _ := rand.Int(rand.Reader, big.NewInt(int64(len(arr))))
		// 1.将 *big.Int 转化为 int64
		// 2.将 int 64 转化为 int
		// 3.将 int 转化为 string
		b = append(b, strconv.Itoa(arr[int(num.Int64())]))
	}

	str := strings.Join(b, "") // 拼接字符串
	a, _ := strconv.Atoi(str)  // string 转 int
	yes := uint32(a)           // int 转 uint32
	return yes
}