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

开篇提问

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 int32
done1 := 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

2. 须要额外进其余不相干的业务，不耽误『主协程』的返回值，不等待

通常有些业务处理之后，有些『额外工做』须要处理可是不耽误主协程返回数据，这个时候就能够开个协程去作，不用等待

// 伪代码

result, err := processMethod()
if err != nil {
    .....
}
// 须要对结果进行写缓存等其余操做，不耽误数据返回
go func() {
    err = saveRedis(result)
    if err != nil {
    	.....
	}
}

return result

3. 对某些任务进行时间限制，『超时关闭』当前操做

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

// 定义两个有缓冲通道，容量分别为1
c1 := 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(msg1)
        case data2 := <-c2:          // 接收c2通道数据（消费数据）
        	fmt.Println(msg2)
        case <-tm.C:
        	fmt.Println("timeout!")
    }
}

篇末提问

1. 使用过协程吗？知道协程与线程的区别吗？
2. 若是是单核CPU，开协程会有用吗？
3. 本文因为没有帮助你提高code能力？
4. 进程通信方式有没有一点点了解？
5. 你会使用本文的协程案例提高运行速度吗？