go语言并发编程(代码片段)

author author     2023-01-18     219

关键词:

一、goroutine

与传统的系统级线程和进程相比,协程的大优势在于其“轻量级”,可以轻松创建上百万个而不会导致系统资源衰竭,而线程和进程通常多也不能超过1万个。这也是协程也叫轻量级线程的原因。
golang原生支持并发编程
轻量级线程
非抢占式多任务处理,由协程主动交出控制权
编译器/解释器/虚拟机层面的多任务
多个协程可能在一个或多个线程上运行

技术分享图片


1.1 go对协程的实现

goroutine--Go对协程的实现
go + 函数名:启动一个协程执行函数体

package main

import (
    "fmt"
    "time"
)

func test_Routine() 
    fmt.Println("This is one routine!!!")


func Add(x, y int) 
    z := x + y
    fmt.Println(z)


func main() 
    for i := 1; i < 10; i++ 
        //启动一个协程执行函数体
        go Add(i, i)
    

    //为避免并发执行后程序立即退出,先sleep 2秒
    time.Sleep(2)

package main

import (
    "fmt"
    "runtime"
    "time"
)

func main() 
    //定义一个数组
    var a [10]int
    //循环并发执行匿名函数,实现
    for i := 0; i < 10; i ++ 
        go func(i int) 
            for 
                a[i]++
                //主动让go协程让出时间片
                runtime.Gosched()
            
        (i)
    
    time.Sleep(time.Millisecond)
    fmt.Println(a)

二、channel

Go语言在语言级别提供的goroutine间的通信方式
不要通过共享来通信,而要通过通信来共享。
channel的读写默认是阻塞的,除非有goroutine对其进行操作。

技术分享图片

package main

import (
    "fmt"
    "strconv"
)

//定义一个加法函数,传入x,y整型参数,quit整型通道
func Add(x, y int, quit chan int) 
    z := x + y
    fmt.Println(z)

    //发送 1 到channel quit
    quit <- 1


//读取channel中的数据
func Read(ch chan int) 
    //将channel中数据发送出去,赋值给value
    value := <-ch

    fmt.Println("value:" + strconv.Itoa(value))


//写数据到channel中
func Write(ch chan int) 
    //ch <- 10


func main() 
    //ch := make(chan int)
    //go Read(ch)
    //go Write(ch)

    //time.Sleep(10)

    //fmt.Println("end of code")

    //定义一个容量为10的非阻塞整型通道切片,变 量名为chs
    chs := make([]chan int, 10)
    //循环地给channel切片chs初始化
    for i := 0; i < 10; i++ 
        chs[i] = make(chan int)
        go Add(i, i, chs[i])
    

    //遍历channel切片chs,并从channel中发出数据,留空
    for _, v := range chs 
        <-v
    

三、缓冲channel

定义: c = make(chan int, n) n为缓冲区的大小,代表channel可以存储多少个元素,这几个元素可以无阻塞的写入,缓存的元素写满之后阻塞,除非有goroutine操作。


例子中定义一个容量为2的channel,


// 缓冲channel
package main

import (
    "fmt"
    "time"
)

// 定义一个chnnel类型变量 ch
var ch chan int

//测试buffered channel函数
func test_channel() 
    // 第一次发送常量1到channel ch
    ch <- 1
    fmt.Println("ch 1")
    // 第二次发送常量1到channel ch
    ch <- 1
    fmt.Println("ch 2")
    // 第三次发送常量1到channel ch
    ch <- 1
    fmt.Println("come to end goroutine 1")


func main() 
    ch = make(chan int, 0) // 等价于 ch = make(chan int) 都是不带缓冲的channel
    ch = make(chan int, 2) // 是带缓冲的channel
    go test_channel()
    time.Sleep(2 * time.Second)
    fmt.Println("running end!")
    <-ch

    time.Sleep(time.Second)


output:
ch 1
ch 2
running end!
come to end goroutine 1

package main

import "fmt"

func main() 
    c := make(chan int, 3   )//修改2为1就报错,修改2为3可以正常运行
    c <- 1
    c <- 2
    fmt.Println(<-c)
    fmt.Println(<-c)

四、select

Linux很早就引入的函数,用来实现非阻塞的一种方式。Go语言直接在语言级别支持select关键字,用于处理异步IO 问题。我们上面介绍的都是只有一个channel的情况,那么如果存在多个channel的时候,我们该如何操作呢,Go里面提供了一个关键字select,通过select可以监听channel上的数据流动。
select默认是阻塞的,只有当监听的channel中有发送或接收可以进行时才会运行,当多个channel都准备好的时候,select是随机的选择一个执行的。

package main

import (
    "fmt"
    "time"
)

func main() 
    ch := make(chan int)

    //匿名函数,传入一个参数整型channel类型ch
    go func(ch chan int) 
        ch <- 1
    (ch)

    time.Sleep(time.Second)

    select 
    //如果ch成功读到数据,则执行下面的语句
    case <-ch:
        fmt.Print("come to read ch!")
    default:
        fmt.Print("come to default!")
    

// 实现超时控制
package main

import (
    "fmt"
    "time"
)

func main() 
    ch := make(chan int)
    //定义一个channel timeout
    timeout := make(chan int, 1)

    //定义一个匿名函数,用来实现超时控制
    go func() 
        time.Sleep( time.Second)
        timeout <- 1
    ()

    select 
    case <-ch:
        fmt.Print("come to read ch!
")
    case <-timeout:
        fmt.Print("come to timeout!
")
    

    fmt.Print("end of code!")

// 使用time.After(time.Second)实现控制
package main

import (
    "fmt"
    "time"
)

func main() 
    ch := make(chan int)

    select 
    case <-ch:
        fmt.Print("come to read ch!
")
    case <-time.After(time.Second):
        fmt.Print("come to timeout!
")
    

    fmt.Print("end of code!")

// goroutine_2.go
package main

import (
    "fmt"
    "runtime"
    "strconv"
    "time"
)

func main() 
    //协程1
    go func() 
        for i := 1; i < 100; i++ 
            if i == 10 
                //主动出让cpu 使用的话 需要 导入 runtime包
                runtime.Gosched()
            
            fmt.Println("routine 1:" + strconv.Itoa(i))
        
    ()

    //协程2
    go func() 
        for i := 100; i < 200; i++ 
            fmt.Println("routine 2:" + strconv.Itoa(i))
        
    ()

    time.Sleep(time.Second)

使用go语言实现高效的并发编程(代码片段)

...竞态条件使用信道来协调多个goroutine之间交互总结概述Go语言支持并发编程。你可以通过创建多个并发单元(称为goroutines)来实现多线程编程。每个goroutine都是一个独立的执行单元,可以并行执行代码。例如,如... 查看详情

使用go语言实现高效的并发编程(代码片段)

...竞态条件使用信道来协调多个goroutine之间交互总结概述Go语言支持并发编程。你可以通过创建多个并发单元(称为goroutines)来实现多线程编程。每个goroutine都是一个独立的执行单元,可以并行执行代码。例如,如... 查看详情

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

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

go语言并发编程(代码片段)

一、goroutine与传统的系统级线程和进程相比,协程的大优势在于其“轻量级”,可以轻松创建上百万个而不会导致系统资源衰竭,而线程和进程通常多也不能超过1万个。这也是协程也叫轻量级线程的原因。golang原生支持并发编... 查看详情

go并发编程模型(代码片段)

一、前言Go语言中实现了两种并发模型,一种是依赖于共享内存实现的线程-锁并发模型,另一种则是CSP(CommunicationingSequentialProcesses,通信顺序进程)并发模型。大多数编程语言(比如C++、Java、Python... 查看详情

go语言并发编程-原子操作(代码片段)

...操作是原子的,即保证本例中n自增到最后的值为1000.示例Go语言代码:packagemainimp 查看详情

go语言并发编程-原子操作(代码片段)

...操作是原子的,即保证本例中n自增到最后的值为1000.示例Go语言代码:packagemainimp 查看详情

go基础并发编程(代码片段)

...nnel的读写单方向channel定时器相关资料Go并发的设计  Go语言最大的特色是并发,而且Go的并发并不像线程或进程那样,受CPU核心数的限制,只要你愿意,你可以启动成千上万个Goroutine协程。相关概念进程:最... 查看详情

go并发编程基础-channel(代码片段)

协程(Goroutine)Go语言中没有线程的概念,只有协程,也称为goroutine。相比线程来说,协程更加轻量,一个程序可以随意启动成千上万个goroutine。goroutine被Goruntime所调度,这一点和线程不一样。也就是说,Go语言的并发是由Go自己... 查看详情

go编程基础(代码片段)

什么是Go?Go是一门并发支持、垃圾回收的编译型系统编程语言,旨在创造一门具有在静态编译语言的高性能和动态语言的高效开发之间拥有良好平衡点的一门编程语言。Go的主要特点:类型安全和内存安全以非常直观和极低代价... 查看详情

go语言基础之并发(代码片段)

并发是编程里面一个非常重要的概念,Go语言在语言层面天生支持并发,这也是Go语言流行的一个很重要的原因。Go语言中的并发编程并发与并行并发:同一时间段内执行多个任务并行:同一时刻执行多个任务Go语言的并发通过goro... 查看详情

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

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

go语言基础之并发(代码片段)

Go语言中的并发编程——并发是编程里面一个非常重要的概念,Go语言在语言层面天生支持并发,这也是Go语言流行的一个很重要的原因。并发与并行并发:同一时间段内执行多个任务(你在用微信和两个女朋友聊天)。并... 查看详情

go语言特点(代码片段)

特点:1.静态类型,编译开源语言。静态类型就是说,必须要指定每一个变量的类型。编译型的意思就是说,go语言程序运行之前,先要把它编译成机器代码。2.脚本化的语法,支持多种编程范式(函数式,面向对象)3.原生,给... 查看详情

图解go并发(代码片段)

你很可能从某种途径听说过Go语言。它越来越受欢迎,并且有充分的理由可以证明。Go快速、简单,有强大的社区支持。学习这门语言最令人兴奋的一点是它的并发模型。Go的并发原语使创建多线程并发程序变得简单而有趣。我将... 查看详情

go语言学习笔记—进阶—并发编程:为函数创建goroutine(代码片段)

使用go关键字为一个函数创建一个goroutine。函数与goroutine是一对多的关系,即可以为一个函数创建多个goroutine,一个goroutine必定只对应一个函数。为普通函数创建goroutine格式为一个go函数创建goroutine,写法如下:go... 查看详情

go语言学习笔记—进阶—并发编程:调整并发的运行性能(gomaxprocs)(代码片段)

go语言的运行时(runtime)实现了一个小型任务调度器,它类似于操作系统的线程调度,可以高效地把CPU资源分配给每一个任务。通过runtime.GOMAXPROCS()函数,可以指定线程池中线程与CPU核心数量的对应关系,如下:... 查看详情

1.go语言简介(代码片段)

Go语言简介引用原文地址:http://m.biancheng.net/golang/Go语言也称Golang,兼具效率、性能、安全、健壮等特性。这套Go语言教程(Golang教程)通俗易懂,深入浅出,既适合没有基础的读者快速入门,也适合工作多年的程序员查阅知识点... 查看详情