广告

扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 后端开发 > GO >详解go语言的并发
  • 153

0
分享到

详解go语言的并发

详解go语言GO并发go语言 2022-06-07 20:06:48 153人浏览 泡泡鱼
摘要

目录1、启动Go语言的协程2、runtime.Goexit()方法。立即终止当前的协程3、runtime.GOMAXPROCS()表示go使用几个cpu执行代码4、管道定义和创

目录

1、启动Go语言的协程

2、runtime.Goexit()方法。立即终止当前的协程

3、runtime.GOMAXPROCS()表示go使用几个cpu执行代码

4、管道定义和创建管道

5、管道的缓冲

6、关闭管道和接受关闭管道的信号

7、只读管道和只写管道和生产者和消费者模型

8、Timer定时器

9、ticker定时器和关闭ticker定时器

10、select语句

11、协程同步锁

12、wait

1、启动go语言的协程 

package main
 
import (
    "fmt"
    "runtime"
)
 
//runtime包
 
func main() {
    //runtime.Gosched() 用于让出cpu时间片，让出这段cpu的时间片，让调度器重新分配资源
 
    //写一个匿名函数
    s := "test"
    go func(s string) {
        for i :=0;i <2;i++ {
            fmt.Println(s)
        }
    }(s)
 
    for i :=0;i <2;i ++ {
        //如果代码跑到这里，调度器会把cpu资源释放出来，让调度器重新分配cpu资源,可以分配到子协程，也可以重新分配到主协程
        runtime.Gosched()
        fmt.Println("123")
    }
}
2、runtime.Goexit()方法。立即终止当前的协程 

package main
 
import (
    "fmt"
    "runtime"
    "time"
)
 
//runtime.Goexit()   立即终止当前的协程
func main() {
    go func() {
        defer fmt.Println("A.defter")
        func () {
            defer fmt.Println("B.defter")
            //立即终止当前的协程，函数会走defer流程
            runtime.Goexit()
            fmt.Println("B")
        }()
        fmt.Println("A")
    }()
    for {
        time.Sleep(2 * time.Second)
    }
}
 
//不加runtime.Goexit()的结果
//B
//B.defter
//A
//A.defter
 
//加runtime.Goexit()的结果
//B.defter
//A.defter
3、runtime.GOMAXPROCS()表示go使用几个cpu执行代码 

package main
 
import (
    "fmt"
    "runtime"
)
 
func main() {
    //runtime.GOMAXPROCS() 表示让go用几个cpu做后面的事情
    n := runtime.GOMAXPROCS(4)
    fmt.Printf("%T--->%p---%d\n",n,n,n)
    for {
        go fmt.Print("0")
        fmt.Print(1)
    }
}
4、管道定义和创建管道 

package main
 
import "fmt"
 
//go语言的协程运行在相同的地址空间，因此访问共享内存必须做好同步，处理好线程安全问题
 
//go语言的协程之间的通信通过协程间通信来共享内存，而不是共享内存来通信
 
//channel是一个引用类型，用于多个协程间通信，内部实现了同步，确保并发安全
 
 
//通道一般是结合协程一起使用
 
 
//如果通道中没有数据，后面你还去取数据，则会报错
//fatal error: all goroutines are asleep - deadlock!
func main() {
    //test45_1 := make(chan int) //定义一个无缓冲的通道
 
    //无缓冲的通道是值在接受数据前没有任何能力保存数据,只能有一个数据进入通道，进入通道后，该通道就会加锁，一直到这个数据被取出，锁才释放
 
    //无缓冲的通道有可能阻塞，如果我发送一个数据到通道，但是没有协程来取数据，则对于第一个协程就被阻塞
 
    //test45_2 := make(chan int,10)  //定义 一个有缓冲的通道
 
 
    //有缓冲的通道就是通道可以存储指定数量的数据，数据在里面也是有顺序的，但是如果缓冲的数量满了，这个通道也会是阻塞的
 
    //
    //test45_1 <- 10   //发送数据到通道
    //<- test45_1      //接受通道中的数据，并丢弃
    //x := <-test45_1 //从通道取值并赋值给x
    //x,ok := <-test45_1  //ok检查通道是否关闭或者是否为空
 
 
    //1、创建一个存放int类型的通道
    test45_1 := make(chan int)
 
    go func() {
        defer fmt.Println("子协程结束")
        fmt.Println("子协程正在运行")
 
        test45_1 <- 111
    }()
    //<- test45_1
    //主协程从通道中取数据
    x := <- test45_1
    fmt.Println(x)
    fmt.Println("主协程结束")
}
5、管道的缓冲 

package main
 
import (
    "fmt"
    "time"
)
 
func main() {
    //无缓冲的通道，长度为0就可以了，有缓冲的通道，这里设置为非0就可以了
    test46_1 := make(chan int,0)
 
    //%P是打印内存地址，%T是打印变量的类型
    //fmt.Printf("长度:%d--->容量:%d---->%P----%T",len(test46_1),cap(test46_1),test46_1,test46_1)
 
    go func() {
        defer fmt.Printf("子协程结束")
 
        for i :=0;i < 3;i ++ {
            fmt.Println("子协程插入数据")
            test46_1 <- i
            //fmt.Printf("长度:%d--->容量:%d---->%P----%T",len(test46_1),cap(test46_1),test46_1,test46_1)
 
        }
 
    }()
 
    time.Sleep(2 * time.Second)
    for j :=0;j <3;j++ {
        fmt.Println("主协程取数据")
        num := <- test46_1
        fmt.Println(num)
    }
}
6、关闭管道和接受关闭管道的信号 

package main
 
import "fmt"
 
//close（）方法，关闭通道的意思
 
func main() {
    test47_1 := make(chan int,4)
 
    go func() {
        for i :=0;i < 10;i ++ {
            test47_1 <- i
        }
        //这个的意思关闭通道test47_1
        close(test47_1)
    }()
 
    //for的写法,遍历通道
    //for {
    //  //子协程关闭了通道，这里ok就可以接收到，这里就可以走到bread流程,ok这个参数表示通道是否关闭
    //  if data,ok := <- test47_1;ok {
    //      fmt.Println(data)
    //  }else {
    //      break
    //  }
    //}
 
    //range的写法，遍历通道
    for data := range test47_1 {
        fmt.Println(data)
    }
    fmt.Println("主协程结束")
}
7、只读管道和只写管道和生产者和消费者模型 

package main
 
import (
    "fmt"
    "time"
)
 
//默认情况下，管道是双向的,既可以写入数据，也可以读出数据。go也可以定义单方向的管道，也就是说只发送数据，或者只写入数据
 
//可以把双向的管道转换为单向的管道，但是不能把单向的管道转换为双向的管道
 
//单方向的管道
 
func producter(out chan <- int)  {
    defer close(out)
    for i := 0;i < 10;i++ {
        out <- i
    }
 
}
 
func consumer(int <-chan int){
    for num := range int {
        fmt.Println(num)
    }
}
func main() {
 
    //1、定义管道
    //定义一个正常的管道
    //var test48_1 chan int
 
    //定义一个单向的只写的管道
    //var test48_2 chan <- float32
 
    //定义一个单向的只读的管道
    //var test48_3 <- chan int
 
    //2、转换管道
 
    //转换正常管道为只写或者只读的管道
    //定义一个正常的管道
    //test48_4 := make(chan int,3)
 
    //把一个正常的管道转换为一个只写的管道
    //var write_only chan <- int = test48_4
 
    //把一个正常的管道转换为一个只读的管道
    //var read_only <- chan int = test48_4
 
 
 
    test48_5 := make(chan int,4)
 
    //启动生产者
    go producter(test48_5)
 
    //启动消费者
    consumer(test48_5)
 
    time.Sleep(10 * time.Millisecond)
    fmt.Println("down")
 
}
8、Timer定时器 

package main
 
import (
    "fmt"
    "time"
)
 
//定时器
 
//time.NewTimer()。时间到了，只执行一次
//time.NewTicker(),周期性的执行
 
func main() {
    //1、创建一个定时器，2s后定时器会将一个时间保存到一个C
    test49_1 := time.NewTimer(2 * time.Second)
 
    //打印系统当前的时间
 
    t1 := time.Now()
 
    fmt.Printf("t1----->%v\n",t1)
 
    //从管道中取出C打印
 
    t2 := <- test49_1.C
    fmt.Printf("t2----->%v\n",t2)
 
 
 
    //2、证明timer只执行一次
    //test49_2 := time.NewTimer(4 * time.Second)
    //
    //for {
    //  c := <- test49_2.C
    //  fmt.Println(c)
    //}
 
    //3、通过timer实现一个延时的功能
 
    //方式1
    //time.Sleep(2 * time.Second)
 
    //方式2
    //test49_3 := time.NewTimer(2 * time.Second)
 
    //方式3
 
    //<-time.After(2 *time.Second)
 
    //4、停止定时器
    test49_4 := time.NewTimer(4 * time.Second)
    //子协程
    go func() {
        //这个意思是3s后才能取出来数据
        <- test49_4.C
 
        fmt.Println("定时器时间到了")
    }()
 
    //关闭定时器
    stop := test49_4.Stop()
    if stop {
        fmt.Println("定时器已经关闭")
    }
 
    //5、重置定时器
    test49_5 := time.NewTimer(4 * time.Second)
    //重置定时器为1s
    test49_5.Reset(1 * time.Second)
 
    for {
 
    }
    }
9、ticker定时器和关闭ticker定时器 

package main
 
import (
    "fmt"
    "time"
)
 
//time.NewTicker()，定时器，响应多次
 
func main() {
    //创建一个定时器，间隔1s
    test50_1 := time.NewTicker(time.Second)
    i := 0
    go func() {
        for {
            c := <- test50_1.C
            fmt.Println(c)
            i ++
            fmt.Println(i)
        }
        }()
 
 
    for {
 
    }
}
10、select语句 

package main
 
import (
    "fmt"
)
 
//go语言提供select关键字，用来监听通道上的数据流动，语法和switch类似,区别是select必须要求每个case语句里必须是一个io操作
 
//如果都能匹配到，则随机选择一个通道去跑，select是比较随便的
 
func main() {
    //test51_1 := make(chan int,3)
    //select {
    //case <- test51_1:
    //  fmt.Println("jja")
    ////如果从通道中可以读出数据，则执行这里
    //case test51_1 <- 1:
    //  fmt.Println("aa")
    ////如果通道中北写入数据，则执行号这里
    //default:
    //  fmt.Println("hah")
    ////如果上面都没成功，则执行这里
    //}
 
 
    test51_1 := make(chan int,1)
    test51_2 := make(chan string,1)
 
    go func() {
        //time.Sleep(2 * time.Second)
        test51_1 <- 1
 
    }()
    go func() {
        test51_2 <- "Hello World"
    }()
 
    select {
    case Value1:= <- test51_1:
        fmt.Println(Value1)
    case Value2 := <- test51_2:
        fmt.Println(Value2)
    }
    fmt.Println("结束")
 
}
11、协程同步锁 

package main
 
import (
    "fmt"
    "sync"
    "time"
)
 
//go语言的协程同步锁，解决并发安全问题
 
 
//取钱的例子
 
type Account struct {
    money int
    flag sync.Mutex
}
 
func Check(a *Account)  {
    time.Sleep(1 * time.Second)
}
 
func (a *Account)SetAccount(n int)  {
    a.money = n
}
 
func (a *Account)GetAccount() (n int) {
    return a.money
}
 
func (a *Account) buy1(n int)  {
    a.flag.Lock()
    if a.money > n {
        Check(a)
        a.money -= n
    }
    a.flag.Unlock()
    fmt.Println(a.money)
}
 
 
func (a *Account) buy2(n int)  {
    a.flag.Lock()
    if a.money > n {
        Check(a)
        a.money -= n
    }
    a.flag.Unlock()
    fmt.Println(a.money)
}
 
func main() {
    var test52_1 Account
    test52_1.SetAccount(10)
 
    go test52_1.buy1(5)
    go test52_1.buy2(6)
    for {
 
    }
}
12、wait

我们自己实现wait


package main
 
import "fmt"
//Add() 计数加1
//Done() 计数减1
//Wait() 主函数调用
func main() {
    test53_1 := make(chan int,2)
    count := 2
    go func() {
        fmt.Println("子协程1")
        test53_1 <- 1
    }()
    go func() {
        fmt.Println("子协程2")
        test53_1 <- 2
    }()
 
    for range test53_1 {
        count --
        if count == 0 {
            fmt.Println("所有的子协程都已经结束")
            close(test53_1)
        }
    }
}

go语言为我们实现wait


package main
 
import (
    "fmt"
    "sync"
)
//Add() 计数加1
//Done() 计数减1
//Wait() 主函数调用
func main() {
 
    var wait_group sync.WaitGroup
 
    //这里就是子协程的个数
    wait_group.Add(2)
    //test54_1 := make(chan int,2)
 
    go func() {
        fmt.Println("子协程1")
        wait_group.Done()
    }()
    go func() {
        fmt.Println("子协程2")
        wait_group.Done()
    }()
 
 
    wait_group.Wait()
    //close(test53_1)
    fmt.Println("所有的子协程都结束")
 
}

以上就是详解go语言的并发的详细内容，更多关于go语言的并发的资料请关注编程网其它相关文章！


您可能感兴趣的文档:
点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: 详解go语言的并发

本文链接: https://www.lsjlt.com/news/30654.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档
去做题
猜你喜欢
  • 详解go语言的并发
    目录1、启动go语言的协程2、runtime.Goexit()方法。立即终止当前的协程3、runtime.GOMAXPROCS()表示go使用几个cpu执行代码4、管道定义和创...
    99+
    2022-06-07
    详解go语言 GO 并发 go语言
  • GO语言并发之好用的sync包详解
    目录sync.Map 并发安全的Mapsync.Once 只执行一次sync.Cond 条件变量控制小结sync.Map 并发安全的Map 反例如下，两个Goroutine分别读写。...
    99+
    2022-12-29
    GO语言 并发 sync包 GO语言 sync包 GO sync包
  • Go语言并发之原子操作详解
    目录修改赋值与读取比较并交换小结代码中的加锁操作因为涉及内核态的上下文切换会比较耗时、代价比较高。针对基本数据类型我们还可以使用原子操作来保证并发安全，因为原子操作是Go语言提供的方...
    99+
    2022-12-29
    Go语言 并发 原子操作 Go语言 原子操作 Go语言 并发
  • Go语言开发保证并发安全实例详解
    目录什么是并发安全？Mutex悲观锁乐观锁版本号机制CAS互斥锁读写互斥锁什么是并发安全？ 在高并发场景下，进程、线程（协程）可能会发生资源竞争，导致数据脏读、脏写、死锁等问题，为了...
    99+
    2022-11-11
  • Go语言中的并发编程：同步机制详解
    在Go语言中，支持并发编程是其一个非常重要的特性。而并发编程中的同步机制也是非常重要的，它能够确保程序的正确性和稳定性。本文将详细介绍Go语言中的同步机制，并通过演示代码来加深理解。 互斥锁（Mutex） 互斥锁是Go语言中最基础的同...
    99+
    2023-08-23
    并发 同步 索引
  • Go语言中map使用和并发安全详解
    目录1 map使用1.1 map定义1.2 map的使用和概念1.3 map的容量1.4 map的使用1.4.1 map的遍历1.4.2 map的删除和断言1.5 map的坑2 并发...
    99+
    2022-11-13
  • 详解go语言中并发安全和锁问题
    首先可以先看看这篇文章，对锁有些了解 GO语言并发编程之互斥锁、读写锁详解 Mutex-互斥锁 Mutex 的实现主要借助了 CAS 指令 + 自旋 + 信号量 数据结构： ty...
    99+
    2022-11-12
  • go语言如何并发
    这篇文章主要介绍“go语言如何并发”的相关知识，小编通过实际案例向大家展示操作过程，操作方法简单快捷，实用性强，希望这篇“go语言如何并发”文章能帮助大家解决问题。Go语言通过编译器运行时（runtime），从语言上支持了并发的特性；并发是...
    99+
    2023-07-05
  • Go语言使用goroutine及通道实现并发详解
    目录使用通道接收数据阻塞接收数据非阻塞接收数据接收任意数据，忽略掉接收的数据循环接收数据使用通道接收数据 在上一篇文章中介绍了通道以及使用通道发送数据，本篇接着了解通道的基本内容，如...
    99+
    2022-11-11
  • Go语言并发编程 互斥锁详情
    目录1、互斥锁Mutex 1.1 Mutex介绍 1.2 Mutex使用实例2、读写锁RWMutex 2.1 RWMutex介绍2.2 RWMutex使用实例1、互斥锁Mutex ...
    99+
    2022-11-12
  • 从并发到并行解析Go语言中的sync.WaitGroup
    目录1. 理解并发与并行2. sync.WaitGroup 的作用和用法2.1 sync.WaitGroup 结构体的定义2.2 sync.WaitGroup 的方法2.3 使用示例...
    99+
    2023-05-19
    Go并发sync.WaitGroup Go sync.WaitGroup用法 Go sync.WaitGroup
  • Go语言通过WaitGroup实现控制并发的示例详解
    目录与Channel区别基本使用示例完整代码特别提示多任务示例完整代码与Channel区别 Channel能够很好的帮助我们控制并发，但是在开发习惯上与显示的表达不太相同，所以在Go...
    99+
    2023-01-30
    Go语言 WaitGroup控制并发 Go语言 WaitGroup
  • Go语言并发编程基础上下文概念详解
    目录前言1 Go 中的 Context2 Context 接口3 Context Tree4 创建上下文4.1 上下文创建函数4.2 Context 使用规范4.3 Context ...
    99+
    2022-11-11
  • Go语言实现的可读性更高的并发神库详解
    目录前言WaitGroup的封装worker池StreamForEach和mapForEachmap总结前言 前几天逛github发现了一个有趣的并发库-conc，其目标是： 更难...
    99+
    2023-01-31
    Go语言可读性并发库 Go 并发库
  • Go语言基础并发channel
    这篇文章主要讲解了“Go语言基础并发channel”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“Go语言基础并发channel”吧！为什么需要channel...
    99+
    2022-10-19
  • Go语言并发编程 sync.Once
    sync.Once用于保证某个动作只被执行一次，可用于单例模式中，比如初始化配置。我们知道init()函数也只会执行一次，不过它是在main()函数之前执行，如果想要在代码执行过程中...
    99+
    2022-11-12
  • go语言限制协程并发数的方案详情
    目录前言一、使用带缓冲的通道限制并发数1.1方案详情1.2评估总结2.2评估总结其它前言 在使用协程并发处理某些任务时, 其并发数量往往因为各种因素的限制不能无限的增大. 例如网络请...
    99+
    2022-11-13
  • Go语言中的并发是什么
    这篇文章主要介绍“Go语言中的并发是什么”，在日常操作中，相信很多人在Go语言中的并发是什么问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Go语言中的并发是什么”的疑惑有所帮...
    99+
    2022-10-18
  • Go语言的接口详解
    目录1、接口的用途2、类型断言3、类型选择4、空接口5、匿名空接口6、实现多个接口7、接口嵌套8、接口零值9、make和new的区别总结接口就是一系列方法的集合（规范行为） 在面向对...
    99+
    2022-11-12
  • Go语言中并发的工作原理
    一、Go语言中Goroutine的基本原理 Go语言里的并发指的是能让某个函数独立于其他函数运行的能力。 Go语言的goroutine是一个独立的工作单元， Go 语言的并发同步模型...
    99+
    2022-11-13
软考高级职称资格查询
软考职称历年真题下载
软考职称资料下载
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作