go语言并发与通道的运用(代码片段)

鸿渐之翼 鸿渐之翼     2023-01-01     693

关键词:

在go语言中我们可以使用goroutine 开启并发。
goroutine 是轻量级线程,goroutine 的调度是由 Golang 运行时进行管理的。
goroutine 语法格式:
go 函数名( 参数列表 )
实例1:

package main

import (
        "fmt"
        "time"
)

func say(s string) 
        for i := 0; i < 5; i++ 
                time.Sleep(100 * time.Millisecond)
                fmt.Println(s)
        


func main() 
        go say("world")
        say("hello")

输出结果:

world
hello
hello
world
world
hello
hello
world
world
hello

我们通过以上程序发现输出结果是没有顺序的

通道(channel)

通道(channel)是用来传递数据的一个数据结构。
实例2:

package main

import "fmt"

func sum(s []int, c chan int) 
        sum := 0
        for _, v := range s 
                sum += v
        
        c <- sum // 把 sum 发送到通道 c


func main() 
        s := []int7, 2, 8, -9, 4, 0

        c := make(chan int)
        go sum(s[:len(s)/2], c)
        go sum(s[len(s)/2:], c)
        x, y := <-c, <-c // 从通道 c 中接收

        fmt.Println(x, y, x+y)

输出结果:

-5 17 12

通道缓冲区

带缓冲区的通道允许发送端的数据发送和接收端的数据获取处于异步状态,就是说发送端发送的数据可以放在缓冲区里,等待接收端去获取数据,而不是立刻需要接收端去获取数据。
实例3:

package main

import "fmt"

func main() 
    // 这里我们定义了一个可以存储整数类型的带缓冲通道
        // 缓冲区大小为2
        ch := make(chan int, 2)

        // 因为 ch 是带缓冲的通道,我们可以同时发送两个数据
        // 而不用立刻需要去同步读取数据
        ch <- 1
        ch <- 2

        // 获取这两个数据
        fmt.Println(<-ch)
        fmt.Println(<-ch)

输出结果:

1
2

Go 遍历通道与关闭通道

实例4:

package main

import (
        "fmt"
)

func fibonacci(n int, c chan int) 
        x, y := 0, 1
        for i := 0; i < n; i++ 
                c <- x
                x, y = y, x+y
        
        close(c)


func main() 
        c := make(chan int, 10)
        go fibonacci(cap(c), c)
        // range 函数遍历每个从通道接收到的数据,因为 c 在发送完 10 个
        // 数据之后就关闭了通道,所以这里我们 range 函数在接收到 10 个数据
        // 之后就结束了。如果上面的 c 通道不关闭,那么 range 函数就不
        // 会结束,从而在接收第 11 个数据的时候就阻塞了。
        for i := range c 
                fmt.Println(i)
        

输出结果:

0
1
1
2
3
5
8
13
21
34

go的通道channel(代码片段)

1、前言作为Go语言最有特色的数据类型,通道(channel)完全可以与goroutine(也可称为go程)并驾齐驱,共同代表Go语言独有的并发编程模式和编程哲学。Don’tcommunicatebysharingmemory;sharememorybycommunicating.(... 查看详情

go的通道channel(代码片段)

1、前言作为Go语言最有特色的数据类型,通道(channel)完全可以与goroutine(也可称为go程)并驾齐驱,共同代表Go语言独有的并发编程模式和编程哲学。Don’tcommunicatebysharingmemory;sharememorybycommunicating.(... 查看详情

go语言学习笔记—进阶—并发编程:通道(channel)——使用channel收发数据(代码片段)

创建channel之后,我们可以使用channel进行数据收发操作。使用channel发送(填充)数据使用特殊的操作符<-,把数据通过channel发送。格式通道变量<-值通道变量是上文通过make创建的通道实例;值可以是变量... 查看详情

go语言学习笔记—进阶—并发编程:通道(channel)——各种各样的通道(代码片段)

单向通道在声明通道时,我们可以设置只发送或只接收。这种被约束操作方向的通道称为单向通道。声明单向通道只发送:chan<-,只接收:<-chanvar通道实例chan<-元素类型//只发送数据var通道实例<-chan元素... 查看详情

go语言通道(代码片段)

背景Golang与其他语言最大的区别是什么呢?在我看来,一个是goroutine,另一个就是通道channel了。其他语言,一般通过共享内存的方式实现不同线程间的通信,也就是说,把数据放在共享内存以供多个线程... 查看详情

七天入门go语言通道&goroutine|第四天并发编程(代码片段)

1.前言在go社区有这样一句话不要通过共享内存来通信,而是通过通信来共享内存。go官方是建议使用管道通信的方式来进行并发。通道是用于协程间交流的通信载体。严格地来说,通道就是数据传输的管道,数据通过... 查看详情

并发——轻量级线程,通道,单向通道(代码片段)

1、轻量级线程goroutine是Go语言中的轻量级线程实现,由Go运行时(runtime)管理。Go程序会智能地将goroutine中的任务合理地分配给每个CPU。Go程序从main包的main()函数开始,在程序启动时,Go程序就会为main()函数创建一个默认的goroutin... 查看详情

15.go语言“避坑”与技巧(代码片段)

Go语言“避坑”与技巧任何编程语言都不是完美的,Go语言也是如此。Go语言的某些特性在使用时如果不注意,也会造成一些错误,我们习惯上将这些造成错误的设计称为“坑”。Go语言的一些设计也具有与其他编程语言不一样的... 查看详情

云原生时代崛起的编程语言go并发编程实战(代码片段)

Go语言是天然并发利器,通过通信来实现内存共享而不是通过共享内存来通信,本篇从了解Go的并发哲学、理论及并发原语开始,之后用一个个Go代码示例认识Go的协程、通道、定时器、互斥锁、池化、原生操作等十几个并发编程... 查看详情

goplgoroutine和通道(代码片段)

Go语言的并发编程风格Go有两种并发编程风格:goroutine和通道(chennle),支持通信顺序进程(CommunicatingSequentialProcess,CSP),CSP是一个并发的模式,在不同的执行体(goroutine)之间传递值,但是变量本身局限于单一的执行体。共享... 查看详情

go语言学习笔记—进阶—并发编程:通道(channel)——在多个goroutine之间通信的管道(代码片段)

单纯地并发执行函数是无意义的,函数之间需要交换数据才能体现并发执行的意义。虽然可以使用“共享内存”的方式交换数据,但共享内存在不同goroutine间易发生竞态问题。为了保证数据交换的正确性,必须使用互... 查看详情

golang✔️走进go语言✔️第十六课协程&通道(代码片段)

【Golang】✔️走进Go语言✔️第十六课协程&通道概述协程并发vs并行进程vs线程vs协程协程并发通道创建通道通道同步概述Golang是一个跨平台的新生编程语言.今天小白就带大家一起携手走进Golang的世界.(第16课)协程协程(Coroutine)... 查看详情

golang✔️走进go语言✔️第十六课协程&通道(代码片段)

【Golang】✔️走进Go语言✔️第十六课协程&通道概述协程并发vs并行进程vs线程vs协程协程并发通道创建通道通道同步概述Golang是一个跨平台的新生编程语言.今天小白就带大家一起携手走进Golang的世界.(第16课)协程协程(Coroutine)... 查看详情

go-通道(代码片段)

  通道类型通道(Channel)是Go语言中一种非常独特的数据结构。它可用于在不同Goroutine之间传递类型化的数据,并且是并发安全的。 通道类型的表示方法很简单,仅由两部分组成chanT在这个类型字面量中,左边是代表... 查看详情

go语言通道(chan)——goroutine之间通信的管道(代码片段)

Go语言通道(chan)——goroutine之间通信的管道如果说goroutine是Go语言程序的并发体的话,那么channels就是它们之间的通信机制。一个channels是一个通信机制,它可以让一个goroutine通过它给另一个goroutine发送值信息。每个channel... 查看详情

go语言并发(代码片段)

...同一时间段执行多个任务并行:同一时刻执行多个任务Go语言的并发通过goroutine实现。goroutine类似于线程,属于用户态的线程,我们可以根据需要创建成千上万个goroutine并发工作。goroutine是由Go语言的运行时调度完成,而线程是... 查看详情

09.go语言并发(代码片段)

Go语言并发并发指在同一时间内可以执行多个任务。并发编程含义比较广泛,包含多线程编程、多进程编程及分布式程序等。本章讲解的并发含义属于多线程编程。Go语言通过编译器运行时(runtime),从语言上支持了并发的特性... 查看详情

关于go并发编程,你不得不知的“左膀右臂”——并发与通道!

...之一。而Golang作为一个出道就自带“高并发”光环的编程语言,其并发编程的实现原理肯定是值得我们深入探究的。本文主要介绍Goroutine和channel的实现。Go并发编程模型在底层是由操作系统所提供的线程库支撑的,这里... 查看详情