Go语言中的通道channel详情

 更新时间:2022年02月25日 16:52:23   作者:酷尔。  
这篇文章主要介绍了Go语言中的通道channel,在Go语言中管道类似于一个数据流,每次放入或者取出一部分数据,数据取出后原通道内的数据就删除掉,在linux操作系统中管道会将函数的返回结果作为下一个函数的参数,下文详细内容需要的朋友可以参考下

一、Go语言通道基础概念

1.channel产生背景

    线程之间进行通信的时候,会因为资源的争夺而产生竟态问题,为了保证数据交换的正确性,必须使用互斥量给内存进行加锁,go语言并发的模型是CSP,提倡通过通信共享内存,而不是通过共享内存而实现通信,通道恰巧满足这种需求。

2.channel工作方式

    channel类似与一个队列,满足先进先出的规则,严格保证收发数据的顺序,每一个通道只能通 过固定类型的数据如果通道进行大型结构体、字符串的传输,可以将对应的指针传进去,尽量的节省空间

二、通道使用语法

1.通道的声明与初始化

    //定义一个通道对象使用,其中int可以换为自己需要的类型
    var a chan int  
    //初始化只有一个位置的通道(第一个参数代表通道类型,第二个参数代表通道有几个位置)
    //位置存满后新的数据将存不进来(阻塞)
    a = make(chan int,1)

2.将数据放入通道内

  • 取出数据使用操作符 <-操作符右是输入变量,操作符左是通道代表数据流入通道内

代码如下:

   // 声明一个通道
    var a chan int
        a <- 5

3.从通道内取出数据

  •  取出数据也使用操作符 <-操作符右是通道,操作符左是接受变量

代码如下:

  //声明一个通道类型
    var a chan int
    fmt.Println("未初始化的通道", a)
    a = make(chan int)
    // wg.Add(1)
    go func(a chan int) {
        // defer wg.Done()
        for {
            x := <-a
            fmt.Println("接收到了数据:", x)
        }
    }(a)

4.关闭通道close

    如果通道重复关闭或者关闭一个没有初始化的通道就会抛出错误

 close(a)//a为待关闭的通道

在并发函数中一次关闭通道代码如下:

// 互斥锁对象
var once sync.Once
//并发函数
//这个函数的目的是将a通道内数据乘以10发送到通道b内
func f2(a <-chan int, b chan<- int) {
    defer wg.Done()
    for {
        x, ok := <-a
        if !ok {
            break
        }
        fmt.Println(x)
        b <- x * 10
    }
    // 确保b通道只关闭一次
    once.Do(func() {
        close(b)
    })
}

三、单项通道及通道的状态分析

1.单项输出通道

    var b <-chan int

2.单项输入通道

    var b chan<- int

示例函数:

//单项通道一般做函数参数,作为一种规范防止通道混用
//此函数完成的功能是将a内的数据乘以10放入通道b内
func f2(a <-chan int, b chan<- int) {
    for {
        x, ok := <-a
        if !ok {
            break
        }
        fmt.Println(x)
        b <- x * 10
    }
}

3.通道的状态

channelnil未初始化空通道满通道非空
接收阻塞阻塞接收值接收值
发送阻塞发送值阻塞发送值
关闭panic关闭成功关闭成功关闭成功
关闭后返回的数据panic返回0值数据读完后返回零值数据读完返回零值

四、通道死锁原因分析

注意以下情况:

在使用通道的时候,从以上表格可知有时会进入阻塞状态,结合waitGroup,如果在主函数等待使用通道的函数执行结束,而使用通道的函数并且通道陷入阻塞状态,如果有其他函数对其进行唤醒则不会死锁,如果没有其他函数可以对其进行唤醒则会抛出死锁异常。

总结:
通道将数据隔离在每一份通道内,在并发的情况下可以很好的使用数据,当然要熟悉通道阻塞的几种情况,避免死锁异常。

到此这篇关于Go语言中的通道channel详情的文章就介绍到这了,更多相关Go语言中的通道channel内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Go语言自带测试库testing使用教程

    Go语言自带测试库testing使用教程

    这篇文章主要为大家介绍了Go语言自带测试库testing使用教程,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-07-07
  • 一文详解Golang中new和make的区别

    一文详解Golang中new和make的区别

    在Go语言中,new和make是两个用于创建对象的内建函数。本文将详细介绍new和make的区别,并通过多个方面的分析和代码示例,帮助大家理解它们的使用场景
    2023-05-05
  • Go语言如何实现TCP通信详解

    Go语言如何实现TCP通信详解

    go里面实现tcp没有像之前写的C++那些那么麻烦,在C++里面要先创建套接字,然后绑定ip地址,go里面直接就一个函数建立套接字,然后在进行通信就可以了,下面这篇文章主要给大家介绍了关于Go语言如何实现TCP通信的相关资料,需要的朋友可以参考下
    2023-01-01
  • go time.After优化后性能提升34%内存减少67%

    go time.After优化后性能提升34%内存减少67%

    这篇文章主要介绍了go语言time.After优化后性能提升34%内存减少67%实例分析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-02-02
  • 解析Golang中引用类型是否进行引用传递

    解析Golang中引用类型是否进行引用传递

    这篇文章主要为大家介绍了Golang中引用类型是否进行引用传递剖析详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-08-08
  • go语言interface接口继承多态示例及定义解析

    go语言interface接口继承多态示例及定义解析

    这篇文章主要为大家介绍了go语言interface接口继承多态示例及定义解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步早日升职加薪
    2022-04-04
  • 多阶段构建优化Go 程序Docker镜像

    多阶段构建优化Go 程序Docker镜像

    这篇文章主要为大家介绍了多阶段构建优化Go 程序Docker镜像,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-08-08
  • Go语言defer的一些神奇规则示例详解

    Go语言defer的一些神奇规则示例详解

    这篇文章主要为大家介绍了Go语言defer的一些神奇规则示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-11-11
  • gin框架中使用JWT的定义需求及解析

    gin框架中使用JWT的定义需求及解析

    这篇文章主要为介绍了gin框架中使用JWT的定义需求及解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步早日升职加薪
    2022-04-04
  • 详解go-zero如何使用validator进行参数校验

    详解go-zero如何使用validator进行参数校验

    这篇文章主要介绍了如何使用validator库做参数校验的一些十分实用的使用技巧,包括翻译校验错误提示信息、自定义提示信息的字段名称、自定义校验方法等,感兴趣的可以了解下
    2024-01-01

最新评论