var count uint32
func sequence(i uint32, fn func()) {
	for {
		//使用原子操作
		if n := atomic.LoadUint32(&count); n == i {
			fn()
			atomic.AddUint32(&count, 1)
			break
		}
		time.Sleep(time.Nanosecond)
	}
}

func main() {
	var times uint32 = 5
	for i := uint32(0); i < times; i++ {
		go func(i uint32) {
			fn := func() {
				fmt.Printf("this i is %v\n", i)
			}
			sequence(i, fn)
		}(i)
	}
	//讓主協(xié)程等待最后執(zhí)行
	sequence(times, func() {})
}

func main() {
	c1 := make(chan struct{})
	c2 := make(chan struct{})
	c3 := make(chan struct{})
	go func() {
		//協(xié)程一 不受限制 直接執(zhí)行 執(zhí)行結(jié)束后關(guān)閉通道一
		fmt.Println("this value is 0")
		close(c1)
	}()
	go func() {
		//協(xié)程二 需要從通道一中接收值 ，或者通道關(guān)閉時，獲取到接收失敗的結(jié)果，否則一直阻塞
		//執(zhí)行結(jié)束后關(guān)閉通道二
		<-c1
		fmt.Println("this value is 1")
		close(c2)
	}()
	go func() {
		//協(xié)程三 需要從通道二中接收值 ，或者通道關(guān)閉時，獲取到接收失敗的結(jié)果，否則一直阻塞
		//執(zhí)行結(jié)束后關(guān)閉通道三
		<-c2
		fmt.Println("this value is 2")
		close(c3)
	}()
	//主協(xié)程 需要從通道三中接收值 ，或者通道關(guān)閉時，獲取到接收失敗的結(jié)果，否則一直阻塞
	<-c3
}

func main() {
	times := 5
	//創(chuàng)建一個互斥鎖數(shù)組 多一個給主協(xié)程用
	var cc = make([]*sync.Mutex, times+1)
	//往數(shù)組中塞入互斥鎖，默認(rèn)直接加鎖
	for i := 0; i < len(cc); i++ {
		m := &sync.Mutex{}
		m.Lock()
		cc[i] = m
	}
	for i := 0; i < times; i++ {
		//創(chuàng)建子協(xié)程
		go func(index int) {
			//子協(xié)程嘗試為數(shù)組中對應(yīng) index 位置的鎖加鎖，獲取不到鎖就等待
			//因為初始化的這些互斥鎖默認(rèn)就已經(jīng)被鎖住了，所以這里創(chuàng)建的子協(xié)程都會被阻塞
			//一旦獲取到鎖，就執(zhí)行邏輯，最后將當(dāng)前index的鎖和index+1的鎖釋放，這樣正在等待 index +1 位置的鎖的子協(xié)程就可以繼續(xù)執(zhí)行了
			cc[index].Lock()
			fmt.Printf("this value is %d \n", index)
			cc[index].Unlock()
			cc[index+1].Unlock()
		}(i)
	}
	//將index 為 0 位置的鎖解鎖，讓第一個子協(xié)程可以繼續(xù)執(zhí)行
	cc[0].Unlock()
	//為 index 為 times 的鎖加鎖，只有當(dāng)最后一個子協(xié)程執(zhí)行完畢后，這個鎖才會解鎖，主協(xié)程才能繼續(xù)向下走
	cc[times].Lock()
	cc[times].Unlock()
}