Golang控制协程执行顺序方法详解

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)
	}
	//让主协程等待最后执行
	sequence(times, func() {})
}

func main() {
	c1 := make(chan struct{})
	c2 := make(chan struct{})
	c3 := make(chan struct{})
	go func() {
		//协程一 不受限制 直接执行 执行结束后关闭通道一
		fmt.Println("this value is 0")
		close(c1)
	}()
	go func() {
		//协程二 需要从通道一中接收值 ，或者通道关闭时，获取到接收失败的结果，否则一直阻塞
		//执行结束后关闭通道二
		<-c1
		fmt.Println("this value is 1")
		close(c2)
	}()
	go func() {
		//协程三 需要从通道二中接收值 ，或者通道关闭时，获取到接收失败的结果，否则一直阻塞
		//执行结束后关闭通道三
		<-c2
		fmt.Println("this value is 2")
		close(c3)
	}()
	//主协程 需要从通道三中接收值 ，或者通道关闭时，获取到接收失败的结果，否则一直阻塞
	<-c3
}

func main() {
	times := 5
	//创建一个互斥锁数组 多一个给主协程用
	var cc = make([]*sync.Mutex, times+1)
	//往数组中塞入互斥锁，默认直接加锁
	for i := 0; i < len(cc); i++ {
		m := &sync.Mutex{}
		m.Lock()
		cc[i] = m
	}
	for i := 0; i < times; i++ {
		//创建子协程
		go func(index int) {
			//子协程尝试为数组中对应 index 位置的锁加锁，获取不到锁就等待
			//因为初始化的这些互斥锁默认就已经被锁住了，所以这里创建的子协程都会被阻塞
			//一旦获取到锁，就执行逻辑，最后将当前index的锁和index+1的锁释放，这样正在等待 index +1 位置的锁的子协程就可以继续执行了
			cc[index].Lock()
			fmt.Printf("this value is %d \n", index)
			cc[index].Unlock()
			cc[index+1].Unlock()
		}(i)
	}
	//将index 为 0 位置的锁解锁，让第一个子协程可以继续执行
	cc[0].Unlock()
	//为 index 为 times 的锁加锁，只有当最后一个子协程执行完毕后，这个锁才会解锁，主协程才能继续向下走
	cc[times].Lock()
	cc[times].Unlock()
}