天天看点

Go语言学习笔记(七)杀手锏 Goroutine + ChannelGoroutineChannelGoroutine+Channel 栗子

加 Golang学习 QQ群共同学习进步成家立业工作 ^-^ 群号:96933959

Go语言的主要的功能在于令人简易使用的并行设计,这个方法叫做Goroutine,通过Goroutine能够让你的程序以异步的方式运行,而不需要担心一个函数导致程序中断,因此Go语言也非常地适合网络服务。

我们通过go让其中一个函数同步运行,如此就不需要等待该函数运行完后才能运行下一个函数。

Goroutine是类似线程的概念(但Goroutine并不是线程)。线程属于系统层面,通常来说创建一个新的线程会消耗较多的资源且管理不易。而 Goroutine就像轻量级的线程,但我们称其为并发,一个Go程序可以运行超过数万个 Goroutine,并且这些性能都是原生级的,随时都能够关闭、结束。一个核心里面可以有多个Goroutine,通过GOMAXPROCS参数你能够限制Gorotuine可以占用几个系统线程来避免失控。

在内置的官方包中也不时能够看见Goroutine的应用,像是net/http中用来监听网络服务的函数实际上是创建一个不断运行循环的Goroutine。

GOMAXPROCS 在调度程序优化后会去掉,默认用系统所有资源。

应用场景,如果某个goroutine panic了,而且这个goroutine里面没有捕获(recover),那么整个进程就会挂掉。所以,好的习惯是每当go产生一个goroutine,就需要写下recover。

<a></a>

channel,管道、队列,先进先出,用来异步传递数据。channel加上goroutine,就形成了一种既简单又强大的请求处理模型,使高并发和线程同步之间代码的编写变得异常简单。

线程安全,多个goroutine同时访问,不需要加锁。

channel是有类型的,一个整数的channel只能存放整数。

开启一个goroutine来放入初始化未指定大小的chan不会报错。

即放即走,在等放入时有来拿数据的,就直接拿走。

关闭chan后再放入数据会 panic: send on closed channel。

chan不关闭取超数据的情况会报 deadlock

chan关闭的情况取超出值为类型默认值,如int为0

判断chan是否取完

利用select来处理chan超时。

time.After()定时器来做处理。

在time.After()计时器触发之前,底层计时器不会被垃圾收集器回收。

 定时器栗子

多个goroutine处理任务;

等待一组channel的返回结果。

等待一组channel的返回结果 sync.WaitGroup 的解决方法。

WaitGroup用于等待一组线程的结束。父线程调用Add方法来设定应等待的线程的数量。每个被等待的线程在结束时应调用Done方法。同时,主线程里可以调用Wait方法阻塞至所有线程结束。