多协程通道的应用---三协程通过通道实现ABC按顺序输出100次

type Info struct {
	semiA chan int
	semiB chan int
	semiC chan int
}
var result int =0
func (in *Info)printA(){
	for{
		in.semiA<-0
		fmt.Println("A")
		in.semiB<-0
	}
}
func (in *Info)printB(){
	for{
		<-in.semiB
		fmt.Println("B")
		in.semiC<-0
	}
}
func (in *Info)printC(){
	for {
		<-in.semiA
		<-in.semiC
		fmt.Println("C")
		//fmt.Println("******************")
		result++
		//fmt.Println(result)
	}
}
func main(){
	start:=new(Info)
	start.semiA=make(chan int)
	start.semiB=make(chan int)
	start.semiC=make(chan int)
	go start.printA()
	go start.printB()
	go start.printC()
	for {
		if result==100{
			fmt.Println("fish ")
			break
		}
	}
	//time.Sleep(1*time.Second)
	defer close(start.semiA)
	defer close(start.semiB)
	defer close(start.semiC)
}

一、先上源码,在做解释

这是我遇见的一到面试题,当时看别人行云流水的写出来后,一直想动手试试,动手后就会发现很多问题,你想使用什么的技术实现线程之间的顺序关系,我最初使用sync.waitgroup,但是我一直没有找到门道,然后转向sync.mutex 使得变得更加复杂。

二、进行思路解释

有三个携程,输出三个对象,三个对象按照指定顺序进行输出,并且限定了数量了,这时我们考虑两件事,第一件事就是按顺序输出,第二件事就是输出指定的数量;

对于顺序,我们利用channal通道来达到输出顺序的要求,A输出后,告诉B可以输出,B输出结束后再告诉C可以输出,C输出后也要告诉A可以继续输出了

对于数量我采取了全局变量的方式,然后再main中循环判断是否达到要求,达到要求后输出并释放掉所有的channal,有不理解的地方可以留言与我讨论

• 编辑
• 预览