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


本文摘自网络,作者runningstarh,侵删。

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

 


相关阅读 >>

Go context机制

Go cassandra 示例2

聊聊Golang的ddd项目结构

Go设计模式之工厂模式浅谈

手撸Golang 结构型设计模式 装饰器模式

了解Go 扁平化项目结构

Golang 有gc吗

Golang学习笔记——面向对象(接口)

Go语言中的反射

Golang 获取win进程信息(pid,进程名称等信息)

更多相关阅读请进入《Go》频道 >>




打赏

取消

感谢您的支持,我会继续努力的!

扫码支持
扫码打赏,您说多少就多少

打开支付宝扫一扫,即可进行扫码打赏哦

分享从这里开始,精彩与您同在

评论

管理员已关闭评论功能...