服务器之家

服务器之家 > 正文

golang基础之Gocurrency并发

时间:2020-05-17 11:37     来源/作者:failymao

goroutine只是由官方实现的超级"线程池"而已,每个实例4-5kb的栈内存占用和用于实现机制而大幅减少的创建和销毁开销。

并发不是并行(多CPU):  Concurrency Is Not Parallelism

并发主要由切换时间片来实现"同时"运行,并行则是直接利用多核实现多线程的运行,但Go可以设置使用核数,以发挥多核计算机的能力。

  • 通过go关键字实现多线程
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
package main
import (
  "fmt"
  "time"
)
 
func Go() {
  fmt.Println("1234...")
 
}
 
func main() {
  go Go()        //go关键字构成多线程
  time.Sleep(2 * time.Second) //主程序睡眠2s
}

Goroutine 奉行通过 通信来共享内存 ,而不是 共享内存来通信 。

Channel

  • Channel是goroutine沟通的桥梁,大都是阻塞同步的
  • 通过make创建,close关闭(当程序简单时,回自动关闭)
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
package main
import (
  "fmt"
)
 
func main() {         //主程序
  c := make(chan bool)   //初始化一个chan类型
  go func() {        //子程序
    fmt.Println("123...") //执行主程序
    c <- true       //通过<-存入bool类型到chan中
  }()
fmt.Println(1)        //程序执行步骤:1st
read_chan := <-c       //<-c 从chan中读取bool,程序执行步骤:2nd
fmt.Println(read_chan)    //程序执行步骤:3rd
}
 
/*output
1st   1     
2nd   123...
3rd   true
*/

注意以上程序的执行顺序(channel无缓存时):先执行读取操作 c<-c ,因为channel中没有值,所以程序发生阻塞,此时执行chanel 写操作 ,然后再执行读操作。

  • Channel是引用类型
  • 可以使用 for range 来迭代不断操作channel
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
package main
import (
  "fmt"
)
 
func main() {
  c := make(chan bool)   //初始化一个chan类型
  go func() {        //go结合匿名函数,构造并发
    fmt.Println("123...") //执行主程序
    c <- true       //通过<-存入bool类型到chan中
    close(c)       //关闭通道:必须明确在哪个地方关闭
  }()
 
  for v := range c {    //for循环chanel
  }
}
 
/*output
  123...
  true
*/
  • 可以设置单向(读&写)或双向通道--默认是双向通道
  • 可以设置缓存大小(默认为0,阻塞),在未被填充前不会发生阻塞(异步),比如缓存20个,可以同时进行20个读操作或者写操作,注意 读的操作先于写的操作
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
package main
import (
  "fmt"
)
 
func main() { //主程序
  c := make(chan bool, 1)  //初始化一个chan类型,缓存为2
  go func() {        //子程序
    fmt.Println("123...") //执行主程序,执行步骤:2
    c <- true       //写操作,执行步骤:2
  }()
  fmt.Println(2)      //执行步骤:1
  fmt.Println(123, <-c)   //读操作,执行步骤:2
  fmt.Println(3)      //执行步骤:3
}
 
/*output
1  2
2  123...
2  123 true
3  3
  */

设置缓存后,程序为异步,读,写操作同时完成,当读取channal中无数据时,也不会造成堵塞,因为与此同时,写操作也将发生。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。

原文链接:http://www.cnblogs.com/failymao/p/9333592.html

标签:

相关文章

热门资讯

歪歪漫画vip账号共享2020_yy漫画免费账号密码共享
歪歪漫画vip账号共享2020_yy漫画免费账号密码共享 2020-04-07
沙雕群名称大全2019精选 今年最火的微信群名沙雕有创意
沙雕群名称大全2019精选 今年最火的微信群名沙雕有创意 2019-07-07
玄元剑仙肉身有什么用 玄元剑仙肉身境界等级划分
玄元剑仙肉身有什么用 玄元剑仙肉身境界等级划分 2019-06-21
男生常说24816是什么意思?女生说13579是什么意思?
男生常说24816是什么意思?女生说13579是什么意思? 2019-09-17
超A是什么意思 你好a表达的是什么
超A是什么意思 你好a表达的是什么 2019-06-06
返回顶部