Golang利用channel协调协程的方法详解

更新时间：2023年05月25日 08:21:28 作者：JetTsang

go 当中的并发编程是通过goroutine来实现的，利用channel（管道）可以在协程之间传递数据，所以本文就来讲讲Golang如何利用channel协调协程吧

前言

go 当中的并发编程是通过goroutine来实现的，利用channel（管道）可以在协程之间传递数据，实现协程的协调与同步。

使用

新建一个管道，使用make channel 来构建

// 构建一个缓存长度为8 的管道
ch := make(chan int ,8)
// 写入
ch <- 10
// 取出
number := <-ch
// 关闭
close(ch)

注意：取数据的时候，如果没得取，会阻塞代码的执行，如果一直没有取到，那就是死锁

实现生产者消费者模式

两个生产者者协程和一个消费者协程

使用waitGroup

func main() {  
    ch := make(chan int, 100)  
    wg := sync.WaitGroup{}  
    wg.Add(2)  
    // 生产者
    go func() {  
        defer wg.Done()  
        // 写入数据  
        for i := 0; i < 10; i++ {  
            ch <- i  
        }  
    }()  
    // 生产者
    go func() {  
        defer wg.Done()  
        // 写入数据  
        for i := 0; i < 10; i++ {  
            ch <- i  
        }  
    }()  
    wg2 := sync.WaitGroup{}  
    wg2.Add(1)  
    // 消费者
    go func() {  
        sum := 0  
        fmt.Printf("sum %d \n", sum)  
        for {  
            // 这里会等待  
            temp, ok := <-ch  
            // close 并且 管道为空，ok = false  
            if !ok {    
                break  
            } else {  
                sum += temp  
            }  
        }  
        fmt.Printf("sum %d \n", sum)  
        wg2.Done()  
    }()  
    // 等待俩生产者结束  
    wg.Wait()  
    // 生产数据之后，消费者也并行读完了，此时可以关闭 管道 来 跳出for循环了 
    close(ch)  
    // 等待消费者协程结束  
    wg2.Wait()  
}

使用管道则将wg2相关的代码改掉

func main() {  
    //... 
    //...
    ch2 := make(chan struct{}, 0)  
    go func() {  
        sum := 0  
        fmt.Printf("sum %d \n", sum)  
        for {  
            // 这里会等待  
            temp, ok := <- ch  
            // close 并且 管道为空，ok = false  
            if !ok {  
                break  
            } else {  
                sum += temp  
            }  
        }  
        fmt.Printf("sum %d \n", sum)  
        ch2 <- struct{}{}  
    }()  
    // 等待俩生产者结束  
    wg.Wait()  
    // 关闭管道
    close(ch)  
    // 等待消费者协程结束  
    <-ch2
}

实战面试题: 「交替打印数字和字母」

题目

使用两个 goroutine 交替打印序列，一个 goroutine 打印数字，另外一个 goroutine 打印字母，最终效果如下：

12AB34CD56EF78GH910IJ1112KL1314MN1516OP1718QR1920ST2122UV2324WX2526YZ2728

解题思路

利用channel的阻塞来协调线程，达到线程交叉执行的效果。

代码

func main() {  
    letter, number := make(chan bool), make(chan bool)  
    wait := sync.WaitGroup{}  
    go func() {  
        i := 1  
        for {  
            if <-number {  
                fmt.Print(i)  
                i++  
                fmt.Print(i)  
                i++  
                letter <- true  
            }  
        }  
    }()  
    wait.Add(1)  
    go func() {  
        // 获得ASCII码  
        i := 'A'  
        for {  
            if <-letter {  
                // 当前已经超过Z时，无需再打印
                if i > 'Z' {  
                    // 停止等待，并且跳出循环
                    wait.Done()  
                    break  
                }  
                // 将ASCII码强转成字母输出  
                fmt.Print(string(i))  
                i++  
                fmt.Print(string(i))  
                i++  
                number <- true  
            }  
        }  
    }()  
    // 放行数字打印的阻塞 
    number <- true  
    // 等待关闭主线程
    wait.Wait()  
}

其实完全也可以将waitGroup换成管道

func main() {  
    letter, number := make(chan bool), make(chan bool)  
    // 再定义一个管道来等待，替代waitGroup的作用
    wait := make(chan bool)
    // 打印数字
    go func() {  
        i := 1  
        for {  
            if <-number {  
                fmt.Print(i)  
                i++  
                fmt.Print(i)  
                i++  
                letter <- true  
            }  
        }  
    }()  
    // 打印字母
    go func() {  
        // 获得ASCII码  
        i := 'A'  
        for {  
            if <-letter {  
                if i > 'Z' {  
                    wait <- true  
                    break  
                }  
                // 将ASCII码强转成字母输出  
                fmt.Print(string(i))  
                i++  
                fmt.Print(string(i))  
                i++  
                number <- true  
            }  
        }  
    }()  
    number <- true  
    // 等待管道取值
    <- wait 
}

到此这篇关于Golang利用channel协调协程的方法详解的文章就介绍到这了,更多相关Golang channel协调协程内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

golang RWMutex读写锁实现读共享写独占的功能示例
在 Go 里除了互斥锁外,还有读写锁 RWMutex,它主要用来实现读共享,写独占的功能,今天我们也顺便分析下读写锁,加深对 Go 锁的理解
2023-09-09
Go语言单向通道的实现
本文主要介绍了Go语言单向通道的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2023-04-04
GoLang调用链可视化go-callvis使用介绍
与链路追踪（Tracing）不同，Tracing关注复杂的分布式环境中各个服务节点间的调用关系，主要用于服务治理。而我们本次探索的代码调用链路则是代码方法级别的调用关系，主要用于代码设计
2023-02-02
golang监听文件变化的实例
这篇文章主要介绍了golang监听文件变化的实例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2021-03-03
Go基础教程系列之回调函数和闭包详解
这篇文章主要介绍了Go基础教程系列之回调函数和闭包详解,需要的朋友可以参考下
2022-04-04
Go语言io pipe源码分析详情
这篇文章主要介绍了Go语言io pipe源码分析详情，pipe是一个适配器,用于连接Reader和Writer，pipe的方法不多,新的写法却不少，并且结构体分两块，读写信道和结束标识，下面进入文章了解具体的内容吧
2022-02-02
go time.After优化后性能提升34%内存减少67%
这篇文章主要介绍了go语言time.After优化后性能提升34%内存减少67%实例分析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-02-02
Go语言sync.Cond基本使用及原理示例详解
这篇文章主要为大家介绍了Go语言sync.Cond基本使用及原理示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-03-03
Go语言高效编程的3个技巧总结
Go语言是一种开源编程语言,可轻松构建简单、可靠且高效的软件,下面这篇文章主要给大家分享介绍了关于Go语言高效编程的3个技巧,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2023-01-01
Golang标准库和外部库的性能比较
这篇文章主要介绍Golang标准库和外部库的性能比较，下面文章讲围绕这两点展开内容，感兴趣的小伙伴可以参考一下
2021-10-10