golang goroutine（协程）和 channel(管道) 案例解析

goroutine和channel概念

• goroutine(协程)，一般我们常见的是进程，线程，进程可以理解为一个软件在运行执行的过程，线程跟协程比较类似，都是单独开辟一块内存，异步执行。不同的是协程占的内存比较小初始栈2KB左右。
• channel(管道) ， 管道实则也是用来存储数据的，那为什么不用切片呢，channel主要用于多个协程之间的通信同步，遵循的是先进先出，channel有容量的限制，如果说一直往里面存，不取的话那管道就会阻塞报错，所以合理处理管道数据，当数据处理完成后，要将管道关闭，不然后面如果要遍历channel时，就会一直等待channel关闭才会执行完成。

开启线程与channel简单通信流程

这里是使用了sync.awitGroup实现多协程异步执行，与channel进行通信过程。

//使用awitGroup用于阻塞主进程作用 等待所有协程执行完成，解除阻塞（类似于计数器，计数器为0，解除阻塞）
var wg sync.awitGroupfunc printNum (ch chan int){for i :=1; i < 10 i++{//循环将i添加到ch管道中，(channel为引用类型，可以直接修改源数据)ch <- i}//关闭管道 在后面我们如果要遍历处理管道数据时，不关闭则接收方会无线阻塞close(ch)//计数器减1wg.Done()
}func readNum (ch chan int){//往ch管道中取数据 打印出来 ，channel时数据消耗性，只要读取了，这条数据不会在channel中保留、for v := range ch{fmt,printIn(v)}}func main {//创建一个channel管道，int类型，容量为10(缓冲区为10)ch:= make(chan int ,10)//计数器加1wg.add(1)//go关键字 开启一个协程 go printNum(ch)//计数器加1wg.add(1)//开启一个协程  协程与协程go readNum(ch)//阻塞主进程wg.awit()fmt.printIn("执行完成")
}

多个工作协程并发执行流程

处理100万个数字内那些是素数，这种数量大的情况下，循环创建多个工作协程，同时执行相关逻辑。

//使用awitGroup用于阻塞主进程作用 等待所有协程执行完成，解除阻塞（类似于计数器，计数器为0，解除阻塞）
var wg sync.awitGroupfunc generateNumbers(inputChan chan int){for i :=2; i < 1000000 i++{//循环将i添加到ch管道中，(channel为引用类型，可以直接修改源数据)inputChan  <- i}//关闭管道 在后面我们如果要遍历处理管道数据时，不关闭则接收方会无线阻塞close(ch)//计数器减1wg.Done()
}func worker(inputChan chan int , outputChan chan int,exitChan chan int){//inputChan 管道中取数据 打印出来 ，channel是数据消耗性，只要读取了，这条数据不会在channel中保留、所以循环worker线程是随机值，是不可能多个工作线程执行一个数值for num := range inputChan {flag := truefor i := 2; i < num; i++ {// 判断如果不为素数 flag为false 则break跳出循环if num%i == 0 {flag = falsebreak}}if flag {primeChan <- num //num 为素数 放在outputChan 管道中}}// 标记减一  与wg.add(1) 配套使用wg.Done()// 因为worker需要多次执行 所以不能直接关闭outputChan 管道// 向exitChan管道中写入数据 记录退出信号exitChan <- true}func listenWorker(exitChan chan int ,outputChan chan int){for i:=1; i < 16; i++{/*从oututChan中取数据，如果循环过程中执行的比工作协程快，没有取到数据，则会阻塞等待，直到outputChan中拿到数据，循环16次，全部协程执行完成。*/<-outputChan}//关闭outputChan管道close(outputChan)//结束监听携程wg.Done()
}func main {//存储100万个待处理数字inputChan:= make(chan int ,1000)//存素数的channel管道outputChan：= make(chan int 1000)//监听多协程结束的信号 容量为16，因为我们就开了16个协程，一般为cpu的逻辑处理器数量exitChan := make(chat bool 16)//计数器加1wg.add(1)//go关键字 开启一个协程 go generateNumbers(inputChan)// 创建工作协程numWorkers := runtime.NumCPU() // 协程数 = CPU 核心数for i := 0; i < numWorkers; i++ {go worker(inputChan, outputChan)}//如何关闭循环的多协程，第二种方案 再开一协程用于实时监听工作协程工作状态wg.add(1)go listenWorker(exitChan,outputChan)//阻塞主进程wg.awit()//如何关闭循环的多协程，第一种方案 在所有协程完成之后,关闭存素数的管道（outputChan）close(outputChan)fmt.printIn("执行完成")
}