Go通道channel通过通信共享内存

目录
  • 引言
    • 通道的声明与创建
    • 接收 & 发送数据

引言

不要通过共享内存来通信 应该通过通信来共享内存

这句话有网友的解释如下：

这句俏皮话具体说来就是，不同的线程不共享内存不用锁，线程之间通讯用通道(channel)同步也用channel。

chanel是协程之间传递信息的媒介，优雅地解决了某些后端开发常用语言中随处可见的lock，unlock，临界区等，把从很多线程层面解决的问题移到协程，从而静态地保证没有数据竞争。

通道的声明与创建

伪代码如下：

//声明类型
var 通道名 chan 数据类型
//创建通道
通道名 = make(chan 数据类型)

实际例子如下：

package main
import "fmt"
func main() {
    var a chan int
    fmt.Printf("%T, %v\n", a, a)
    if a == nil {
        a = make(chan int)
        fmt.Printf("%T, %v\n", a, a)
    }
}

运行结果是：

chan int, <nil>
chan int, 0x1400001a360

通道是一个内存地址，这也说明了其实一个引用类型的数据。

接收 & 发送数据

对于同一个通道来讲,他的读数据 和 写数据 都是阻塞的。
伪代码如下：

//从通道读数据
data := <-a
//把数据写入通道
a <- data

实际例子如下：

package main
import "fmt"
func main() {
    //    首先创建一个bool类型的通道
    var ch1 chan bool
    ch1 = make(chan bool)
    //下面启动一个go routine
    go func() {
        for i := 0; i &lt; 10; i++ {
            fmt.Println("子goroutine中， i: ", i)
        }
        fmt.Println("completed")
        //循环结束后 向团队中写数据，表示要结束了
        ch1 &lt;- true
    }()
    //在主程序中读取数据
    data := &lt;-ch1
    //打印一下 我们读到的数据
    fmt.Println("main  data: ", data)
    fmt.Println("main goroutine completed")
}

运行结果如下：

子goroutine中， i: 0
子goroutine中， i: 1
子goroutine中， i: 2
子goroutine中， i: 3
子goroutine中， i: 4
子goroutine中， i: 5
子goroutine中， i: 6
子goroutine中， i: 7
子goroutine中， i: 8
子goroutine中， i: 9
completed
main data: true
main goroutine completed

我们的子goroutine里面 循环打印1~10， 打印完成之后 把chanel类型的ch1写为true，
这时候，主goroutine就可以根据这一条件进行下一步了，，在此之前，其实就算主goroutine先抢到了资源，从ch1中读取数据，但是现在通道里面啥都没有，只能阻塞，然后乖乖交出资源给我们的子goroutine，直到循环结束写true入ch1。

需要注意的有以下几点：

  • chanel是需要指定类型的 nil类型的chanel不能直接使用。
  • chanel本身是同步的，同一时间只能有一条goroutine进行操作。
  • chanel是goroutine之间传递数据用的，chanel数据的发送和接收必须在不同的goroutine中，如果只有一条goroutine是用不上chanel的，这种情况会发生死锁（deadLock）。
  • 从chanel里面读数据立马就会被阻塞，直到有向chanel写数据的goroutine来。
  • 向chanel里面写数据立马就会被阻塞，直到有从chanel读数据的goroutine来。

（以上都是相对于没有缓存的通道而言，后面讲到的缓存通道在缓冲区满的时候才阻塞，而不是立刻阻塞）

以上就是Go通道channel通过通信共享内存的详细内容，更多关于Go channel通信共享内存的资料请关注我们其它相关文章！

赞 (0)

相关推荐

  • Go中Channel发送和接收操作指南

    目录 前言 一.Channel的定义 二.Channel的操作 三.Channel发送和接收操作的特点 四.Channel的类型 五.Channel的源码学习 总结 前言 先来看一道面试题: 对已经关闭的 chan 进行读写,会怎么样?为什么? 在上一篇学习 Go 协程的文章中,知道 go 关键字可以用来开启一个 goroutine 进行任务处理,但多个任务之间如果需要通信,就需要用到通道(channel)了. 一.Channel的定义 声明并初始化一个通道,可以使用 Go 语言的内建函数 ma

  • GO使用socket和channel实现简单控制台聊天室

    使用socket和channel,实现简单控制台聊天室 这里使用socket和channel,演示在GO中如何编写一个简单网络程序 功能分析 聊天室主要功能:用户可以加入/离开聊天室:每个用户发送的消息,广播给所有人 聊天室分为客户端和服务端,客户端负责发送消息和打印服务器消息,服务器负责接收客户端消息,并广播给所有人 客户端可以使用telnet程序 服务端是需要实现的.需要实现的功能, 如何保存多个客户端的连接,管理连接的接入与断开 如何接收和广播客户端消息 实现思路 通过功能分析,拆分为聊天

  • golang channel管道使用示例解析

    目录 定义channel管道 channel管道塞值和取值 通过channel管道实现同步,和数据交互 无缓冲的channel 有缓冲的channel管道 关闭channel管道 单向channel管道,读写分离 管道消费者生产者模型 定义channel管道 定义一个channel时,也需要定义发送到管道的值类型.channel可以使用内置的make()函数来创建: var ch = make(chan int) //等价于:make(chan Type,0) var ch = make(cha

  • Django实现WebSocket在线聊天室功能(channels库)

    Django实现WebSocket在线聊天室功能(channels库)

    1.Django实现WebSocket在线聊天室 1.1 安装 pip install channels==2.3 (saas) F:\Desktop\Python_Study\CHS-Tracer\saas>pip install channels==2.3 Looking in indexes: http://mirrors.aliyun.com/pypi/simple/ Collecting channels==2.3   Downloading   ... Successfully in

  • Golang中channel的原理解读(推荐)

    Golang中channel的原理解读(推荐)

    数据结构 channel的数据结构在$GOROOT/src/runtime/chan.go文件下: type hchan struct { qcount uint // 当前队列中剩余元素个数 dataqsiz uint // 环形队列长度,即可以存放的元素个数 buf unsafe.Pointer // 环形队列指针 elemsize uint16 // 每个元素的大小 closed uint32 // 标记是否关闭 elemtype *_type // 元素类型 sendx uint //

  • GO语言协程创建使用并通过channel解决资源竞争

    目录 创建协程 主协程终止,子协程也终止 runtime包 Gosched让出CPU时间片 Goexit立即结束当前协程 GOMAXPROCS设置并行CPU核数最大值,并返回之前的值 runtime.NumGoroutine()获取当前运行中的goroutine数量 多任务资源竞争问题 通过channel解决资源竞争问题 主协程如何等其余协程完再退出 创建协程 goroutine是go的设计核心,就是协程主协程终止了,子协程也终止 package main import ( "fmt"

  • 深入理解Golang Channel 的底层结构

    深入理解Golang Channel 的底层结构

    目录 make chan 发送和接收 Goroutine Pause/Resume wait empty channel Golang 使用 Groutine 和 channels 实现了 CSP(Communicating Sequential Processes) 模型,channles在 goroutine 的通信和同步中承担着重要的角色. 在GopherCon 2017 中,Golang 专家 Kavya 深入介绍了 Go Channels 的内部机制,以及运行时调度器和内存管理系统是如

  • Go通道channel通过通信共享内存

    目录 引言 通道的声明与创建 接收 & 发送数据 引言 不要通过共享内存来通信 应该通过通信来共享内存 这句话有网友的解释如下: 这句俏皮话具体说来就是,不同的线程不共享内存不用锁,线程之间通讯用通道(channel)同步也用channel. chanel是协程之间传递信息的媒介,优雅地解决了某些后端开发常用语言中随处可见的lock,unlock,临界区等,把从很多线程层面解决的问题移到协程,从而静态地保证没有数据竞争. 通道的声明与创建 伪代码如下: //声明类型 var 通道名 chan 数

  • C#.Net通信共享内存映射文件Memory Mapped

    C#.Net通信共享内存映射文件Memory Mapped

    目录 内存映射文件究竟是个什么? .Net 共享内存 内存映射文件原理 C# .Net 共享内存 演示代码 C# .Net 进程间通信共享内存 IMServer_Message.exe 代码 IMServer_State.exe代码 节点通信存在两种模型:共享内存(Shared memory)和消息传递(Messages passing). 内存映射文件对于托管世界的开发人员来说似乎很陌生,但它确实已经是很远古的技术了,而且在操作系统中地位相当.实际上,任何想要共享数据的通信模型都会在幕后使用它

  • Go语言中的通道channel详情

    目录 一.Go语言通道基础概念 1.channel产生背景 2.channel工作方式 二.通道使用语法 1.通道的声明与初始化 2.将数据放入通道内 3.从通道内取出数据 4.关闭通道close 三.单项通道及通道的状态分析 1.单项输出通道 2.单项输入通道 3.通道的状态 四.通道死锁原因分析 一.Go语言通道基础概念 1.channel产生背景 线程之间进行通信的时候,会因为资源的争夺而产生竟态问题,为了保证数据交换的正确性,必须使用互斥量给内存进行加锁,go语言并发的模型是CSP,提倡

  • node 利用进程通信实现Cluster共享内存

    Node.js的标准API没有提供进程共享内存,然而通过IPC接口的send方法和对message事件的监听,就可以实现一个多进程之间的协同机制,通过通信来操作共享内存. ##IPC的基本用法: // worker进程 发送消息 process.send('读取共享内存'); // master进程 接收消息 -> 处理 -> 发送回信 cluster.on('online', function (worker) { // 有worker进程建立,即开始监听message事件 worker.o

  • PHP进程通信基础之信号量与共享内存通信

    由于进程之间谁先执行并不确定,这取决于内核的进程调度算法,其中比较复杂.由此有可能多进程在相同的时间内同时访问共享内存,从而造成不可预料的错误.信号量这个名字起的令人莫名其妙,但是看其英文原意,就十分容易理解. semaphore 英[ˈseməfɔ:(r)] vt. 发出信号,打旗语; 类似于指挥官的作用. 下面我们看下一个伪代码信号量的使用. 1.创建信号量唯一标识符 $ftok = ftok(__FILE__, 'a'); 2.创建信号量资源ID $sem_resouce_id = sem

  • 解决Pytorch自定义层出现多Variable共享内存错误问题

    错误信息: RuntimeError: in-place operations can be only used on variables that don't share storage with any other variables, but detected that there are 4 objects sharing it 自动求导是很方便, 但是想想, 如果两个Variable共享内存, 再对这个共享的内存的数据进行修改, 就会引起错误! 一般是由于 inplace操作或是ind

  • Linux共享内存实现机制的详解

    Linux共享内存实现机制的详解

    Linux共享内存实现机制的详解 内存共享: 两个不同进程A.B共享内存的意思是,同一块物理内存被映射到进程A.B各自的进程地址空间.进程A可以即时看到进程B对共享内存中数据的更新,反之亦然.由于多个进程共享同一块内存区域,必然需要某种同步机制,互斥锁和信号量都可以. 效率: 采用共享内存通信的一个显而易见的好处是效率高,因为进程可以直接读写内存,而不需要任何数据的拷贝.对于像管道和消息队列等通信方式,则需要在内核和用户空间进行四次的数据拷贝,而共享内存则只拷贝两次数据[1]: 一次从输入文件到

  • 详解Linux进程间通信——使用共享内存

    详解Linux进程间通信——使用共享内存

    一.什么是共享内存 顾名思义,共享内存就是允许两个不相关的进程访问同一个逻辑内存.共享内存是在两个正在运行的进程之间共享和传递数据的一种非常有效的方式.不同进程之间共享的内存通常安排为同一段物理内存.进程可以将同一段共享内存连接到它们自己的地址空间中,所有进程都可以访问共享内存中的地址,就好像它们是由用C语言函数malloc分配的内存一样.而如果某个进程向共享内存写入数据,所做的改动将立即影响到可以访问同一段共享内存的任何其他进程. 特别提醒:共享内存并未提供同步机制,也就是说,在第一个进程结束

  • PHP共享内存使用与信号控制实例分析

    本文实例讲述了PHP共享内存使用与信号控制.分享给大家供大家参考,具体如下: 共享内存 共享内存的使用主要是为了能够在同一台机器不同的进程中共享一些数据,比如在多个 php-fpm 进程中共享当前进程的使用情况.这种通信也称为进程间通信(Inter-Process Communication),简称 IPC. PHP 内置的 shmop 扩展 (Shared Memory Operations) 提供了一系列共享内存操作的函数(可能是用的人不多吧,这一块儿的文档还没有中文翻译).在 Linux

  • nginx共享内存机制详解

    nginx共享内存机制详解

    nginx的共享内存,是其能够实现高性能的主要原因之一,而其主要是用于对文件的缓存.本文首先会讲解共享内存的使用方式,然后会讲解nginx是如何实现共享内存的管理的. 1. 使用示例 nginx声明共享内存的指令为: proxy_cache_path /Users/Mike/nginx-cache levels=1:2 keys_zone=one:10m max_size=10g inactive=60m use_temp_path=off; 这里只是声明的一个名称为one,最大可用内存为10g

随机推荐