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

runningstarh · · 780 次点击 · · 开始浏览

这是一个创建于的文章，其中的信息可能已经有所发展或是发生改变。

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，有不理解的地方可以留言与我讨论

有疑问加站长微信联系（非本文作者）