聊聊并发,进程通信方式,go协程简单应用场景

mb6004f7ec10a08 · · 206 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

开篇提问

  1. 知道并发,并行,线程,协程概念吗?或者知道大概含义吗?
  2. 有线程为什么还要有协程?区别是什么?
  3. 『进程』通信方式知道几种?有没有超过3种?
  4. golang『协程』通信方式推荐?
  5. 使用并发的目的是为什么?是能帮我们解决什么问题吗?

概念

并发,线程,协程:概念是不可能概念的,google去吧。或者点击这里,查看上一篇文章

  • 并行:一般是指多个CPU实例或者多台机器在『同一时刻』同时执行某个逻辑(方法)

『进程』通信方式

名称特点
管道/匿名管道(pipe)管道的实质是一个内核缓冲区
有名管道(FIFO)先进先出(first in first out);
以有名管道的文件形式存在于文件系统中;
信号(Signal)无需知道该进程的状态;
阻塞进程;
异步通信;
消息队列(Message Queue)放在内核中的消息链表;
允许一个或多个进程向它写入与读取消息;
克服了信号承载信息量少缺陷;
目前主要有两种类型的消息队列:POSIX消息队列以及System V消息队列,系统V消息队列目前被大量使用;
共享内存(share memory)使得多个进程可以可以直接读写同一块内存空间,是最快的可用IPC形式;
由于多个进程共享一段内存,因此需要依靠某种同步机制(如信号量)来达到进程间的同步及互斥;
信号量(semaphore)信号量是一个计数器,用于多进程对共享数据的访问,信号量的意图在于进程间同步只能通过两个标准原子操作:wait(semap) , signal(semap) ;进行访问
信号量是非负整型变量
操作也被成为PV原语(P来源于荷兰语proberen"测试",V来源于荷兰语verhogen"增加",P表示通过的意思,V表示释放的意思)
套接字(socket)套接字是支持TCP/IP的网络通信的基本操作单元
套接字的特性由3个属性确定,它们分别是:域、端口号、协议类型。

信号量与互斥量之间的区别:(1)互斥量用于线程的互斥,信号量用于线程的同步。这是互斥量和信号量的根本区别,也就是互斥和同步之间的区别。 **互斥:**是指某一资源同时只允许一个访问者对其进行访问,具有唯一性和排它性。但互斥无法限制访问者对资源的访问顺序,即访问是无序的。 **同步:**是指在互斥的基础上(大多数情况),通过其它机制实现访问者对资源的有序访问。 在大多数情况下,同步已经实现了互斥,特别是所有写入资源的情况必定是互斥的。少数情况是指可以允许多个访问者同时访问资源 (2)互斥量值只能为0/1,信号量值可以为非负整数。 也就是说,一个互斥量只能用于一个资源的互斥访问,它不能实现多个资源的多线程互斥问题。信号量可以实现多个同类资源的多线程互斥和同步。当信号量为单值信号量是,也可以完成一个资源的互斥访问。 (3)互斥量的加锁和解锁必须由同一线程分别对应使用,信号量可以由一个线程释放,另一个线程得到。

go协程通讯使用

基本上就是推荐使用channel,这个是最推荐的使用形式;

还有就是使用sync.Mutex互斥锁进行加锁通讯;

更详细的介绍以后写;

go使用协程一些应用场景,简单举例

  1. 进行互不相干的『循环』,需要等待结果计算

这种情况下,一般是不同『数据集合』需要进行『处理』,在处理的过程中两个数据集合对『结果』造成的影响没有时序行;

这种情况下,完全可以采用两个数据单独进行协程处理然后再进行后续运算;

// 伪代码var result, data1, data2 int32done1 := make(chan bool)
done2 := make(chan bool)// 第一个数据集合,需要求和go func() {for _, val := range dataset1 {
        data1 += val
    }
    done1 <- true}// 第二个数据集合,需要求和go func() {for _, val := range dataset2 {
        data2 += val
    }
    done2 <- true}// 等待协程完成运算<-done1
<-done2// 结果进行相加result = data1 + data2复制代码
  1. 需要额外进其他不相干的业务,不耽误『主协程』的返回值,不等待

一般有些业务处理以后,有些『额外工作』需要处理但是不耽误主协程返回数据,这个时候就可以开个协程去做,不用等待

// 伪代码result, err := processMethod()if err != nil {
    .....
}// 需要对结果进行写缓存等其他操作,不耽误数据返回go func() {
    err = saveRedis(result)if err != nil {
    	.....
	}
}return result复制代码
  1. 对某些任务进行时间限制,『超时关闭』当前操作

例如,通过管道channel发送某些数据,若超时则自动放弃本次发送,关闭通道。

// 定义两个有缓冲通道,容量分别为1c1 := make(chan string, 1) 
c2 := make(chan string, 1)go func() {                     
    time.Sleep(time.Second * 1) // 隔1秒发送数据c1 <- "data1"        }()go func() {
    time.Sleep(time.Second * 6) // 隔6秒发送数据c2 <- "data2"             }()for i := 0; i < 2; i++ {    // 给通道创建容忍时间,如果5s内无法读写,就即刻返回tm := time.NewTimer(time.Second * 5) // 使用select来获取这两个通道的值,然后输出select {case data1 := <-c1:          // 接收c1通道数据(消费数据)	fmt.Println(data1)case data2 := <-c2:          // 接收c2通道数据(消费数据)	fmt.Println(data2)case <-tm.C:
        	fmt.Println("timeout!")
    }
}复制代码

篇末提问

  1. 使用过协程吗?知道协程与线程的区别吗?
  2. 如果是单核CPU,开协程会有用吗?
  3. 本文由于没有帮助你提升code能力?
  4. 进程通讯方式有没有一点点了解?
  5. 你会使用本文的协程案例提升运行速度吗?

有疑问加站长微信联系(非本文作者)

本文来自:51CTO博客

感谢作者:mb6004f7ec10a08

查看原文:聊聊并发,进程通信方式,go协程简单应用场景

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:701969077

206 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传