Go中sync 包Cond使用场景分析

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

func main() {
	c := sync.NewCond(&sync.Mutex{})
	num := 0
	// 当前叫号是几号
	hand_num := 0
	for i := 0; i < 5; i++ {
		go func(i int) {
			// 分别在不同时间排队
			time.Sleep(time.Second * time.Duration(rand.Int63n(10)))
			c.L.Lock()
			num++
			// 当前取得号。
			cur := num
			fmt.Printf("%s  %d 号病人取到了 %d 号\n", time.Now().Format("2006-01-02 15:04:05"), i, cur)
			// 取到号了，等待叫号
			c.Wait()
			fmt.Printf("%s  %d 号病人排队号是 %d 号，被叫号了\n", time.Now().Format("2006-01-02 15:04:05"), i, cur)
			hand_num = cur
			c.L.Unlock()
		}(i)
	}

	// 都叫号了
	for hand_num != 5 {
		// 叫号
		c.Signal()
		time.Sleep(time.Second * 1)
	}

	time.Sleep(time.Second * 10)
}

package main

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

func main() {
	c := sync.NewCond(&sync.Mutex{})

	for i := 0; i < 10; i++ {
		go func(i int) {
			// 随机一个8秒内的准备时间
			time.Sleep(time.Second * time.Duration(rand.Int63n(8)))
			fmt.Printf("%s 运动员%d已准备就绪\n", time.Now().Format("2006-01-02 15:04:05"), i)
			c.L.Lock()
			// 准备完毕，等待教练发令
			c.Wait()
			c.L.Unlock()
			fmt.Printf("%s 运动员%d开跑\n", time.Now().Format("2006-01-02 15:04:05"), i)
		}(i)
	}

	// 主协程等待10秒后发令
	time.Sleep(time.Second * 10)
	fmt.Printf("%s 教练发令。\n", time.Now().Format("2006-01-02 15:04:05"))
	// 教练发令。通知所有运动员开始跑步， 即唤起之前 wait()的所有协程
	c.Broadcast()
	// 等待跑步
	time.Sleep(time.Second * 5)
}