golang基础之Gocurrency并发

goroutine只是由官方实现的超级"线程池"而已，每个实例4-5kb的栈内存占用和用于实现机制而大幅减少的创建和销毁开销。

并发不是并行（多CPU）:  Concurrency Is Not Parallelism

并发主要由切换时间片来实现"同时"运行，并行则是直接利用多核实现多线程的运行，但Go可以设置使用核数，以发挥多核计算机的能力。

  • 通过go关键字实现多线程
package main
import (
  "fmt"
  "time"
)

func Go() {
  fmt.Println("1234...") 

}

func main() {
  go Go()        //go关键字构成多线程
  time.Sleep(2 * time.Second) //主程序睡眠2s
}

Goroutine 奉行通过 通信来共享内存 ，而不是 共享内存来通信 。

Channel

  • Channel是goroutine沟通的桥梁，大都是阻塞同步的
  • 通过make创建，close关闭（当程序简单时，回自动关闭）
package main
import (
  "fmt"
)

func main() {         //主程序
  c := make(chan bool)   //初始化一个chan类型
  go func() {        //子程序
    fmt.Println("123...") //执行主程序
    c <- true       //通过<-存入bool类型到chan中
  }()
fmt.Println(1)        //程序执行步骤：1st
read_chan := <-c       //<-c 从chan中读取bool，程序执行步骤：2nd
fmt.Println(read_chan)    //程序执行步骤：3rd
}

/*output
1st   1
2nd   123...
3rd   true
*/

注意以上程序的执行顺序(channel无缓存时)：先执行读取操作 c<-c ，因为channel中没有值，所以程序发生阻塞，此时执行chanel 写操作 ，然后再执行读操作。

  • Channel是引用类型
  • 可以使用 for range 来迭代不断操作channel
package main
import (
  "fmt"
)

func main() {
  c := make(chan bool)   //初始化一个chan类型
  go func() {        //go结合匿名函数，构造并发
    fmt.Println("123...") //执行主程序
    c <- true       //通过<-存入bool类型到chan中
    close(c)       //关闭通道:必须明确在哪个地方关闭
  }()

  for v := range c {    //for循环chanel
  }
}

/*output
  123...
  true
*/
  • 可以设置单向(读&写)或双向通道--默认是双向通道
  • 可以设置缓存大小（默认为0，阻塞），在未被填充前不会发生阻塞（异步），比如缓存20个，可以同时进行20个读操作或者写操作，注意 读的操作先于写的操作
package main
import (
  "fmt"
)

func main() { //主程序
  c := make(chan bool, 1)  //初始化一个chan类型,缓存为2
  go func() {        //子程序
    fmt.Println("123...") //执行主程序，执行步骤：2
    c <- true       //写操作，执行步骤：2
  }()
  fmt.Println(2)      //执行步骤：1
  fmt.Println(123, <-c)   //读操作，执行步骤：2
  fmt.Println(3)      //执行步骤：3
}

/*output
1  2
2  123...
2  123 true
3  3
  */

设置缓存后，程序为异步，读，写操作同时完成，当读取channal中无数据时，也不会造成堵塞，因为与此同时，写操作也将发生。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。

赞 (0)

相关推荐

  • 详解Golang 中的并发限制与超时控制

    前言 上回在 用 Go 写一个轻量级的 ssh 批量操作工具里提及过,我们做 Golang 并发的时候要对并发进行限制,对 goroutine 的执行要有超时控制.那会没有细说,这里展开讨论一下. 以下示例代码全部可以直接在 The Go Playground上运行测试: 并发 我们先来跑一个简单的并发看看 package main import ( "fmt" "time" ) func run(task_id, sleeptime int, ch chan st

  • 如何利用Golang写出高并发代码详解

    前言 之前一直对Golang如何处理高并发http请求的一头雾水,这几天也查了很多相关博客,似懂非懂,不知道具体代码怎么写 下午偶然在开发者头条APP上看到一篇国外技术人员的一篇文章用Golang处理每分钟百万级请求,看完文章中的代码,自己写了一遍代码,下面自己写下自己的体会 核心要点 将请求放入队列,通过一定数量(例如CPU核心数)goroutine组成一个worker池(pool),workder池中的worker读取队列执行任务 实例代码 以下代码笔者根据自己的理解进行了简化,主要是表达出

  • golang实现并发数控制的方法

    golang并发 谈到golang这门语言,很自然的想起了他的的并发goroutine.这也是这门语言引以为豪的功能点.并发处理,在某种程度上,可以提高我们对机器的使用率,提升系统业务处理能力.但是并不是并发量越大越好,太大了,硬件环境就会吃不消,反而会影响到系统整体性能,甚至奔溃.所以,在使用golang提供便捷的goroutine时,既要能够实现开启并发,也要学会如果控制并发量. 开启golang并发 golang开启并发处理非常简单,只需要在调用函数时,在函数前边添加上go关键字即可.如下

  • golang高并发的深入理解

    golang高并发的深入理解

    前言 GO语言在WEB开发领域中的使用越来越广泛,Hired 发布的<2019 软件工程师状态>报告中指出,具有 Go 经验的候选人是迄今为止最具吸引力的.平均每位求职者会收到9 份面试邀请. 想学习go,最基础的就要理解go是怎么做到高并发的. 那么什么是高并发? 高并发(High Concurrency)是互联网分布式系统架构设计中必须考虑的因素之一,它通常是指,通过设计保证系统能够同时并行处理很多请求. 严格意义上说,单核的CPU是没法做到并行的,只有多核的CPU才能做到严格意义上的并行

  • golang中sync.Map并发创建、读取问题实战记录

    背景: 我们有一个用go做的项目,其中用到了zmq4进行通信,一个简单的rpc过程,早期远端是使用一个map去做ip和具体socket的映射. 问题 大概是这样 struct SocketMap { sync.Mutex sockets map[string]*zmq4.Socket } 然后调用的时候的代码大概就是这样的: func (pushList *SocketMap) push(ip string, data []byte) { pushList.Lock() defer pushLi

  • Golang极简入门教程（三）：并发支持

    Golang 运行时(runtime)管理了一种轻量级线程,被叫做 goroutine.创建数十万级的 goroutine 是没有问题的.范例: 复制代码 代码如下: package main   import (     "fmt"     "time" )   func say(s string) {     for i := 0; i < 5; i++ {         time.Sleep(100 * time.Millisecond)       

  • golang基础之Gocurrency并发

    goroutine只是由官方实现的超级"线程池"而已,每个实例4-5kb的栈内存占用和用于实现机制而大幅减少的创建和销毁开销. 并发不是并行(多CPU):  Concurrency Is Not Parallelism 并发主要由切换时间片来实现"同时"运行,并行则是直接利用多核实现多线程的运行,但Go可以设置使用核数,以发挥多核计算机的能力. 通过go关键字实现多线程 package main import ( "fmt" "time

  • golang基础之waitgroup用法以及使用要点

    目录 一.前言 二.waitgroup使用示例 三.waitgroup使用注意事项 四.waitgroup使用总结 附:陷阱避免 总结 一.前言 waitgroup在golang中,用于线程同步,指等待一个组,等待一个系列执行完成后,才会向下执行,可以解决一个 进程goroutine 等待多个该进程启动的子线程goroutine 都正常运行完成的场景,这个比较常见的场景就是例如 后端 main processer 启动了多个消费者worker干活,还有爬虫并发爬取数据,多线程下载等等,为了保证主

  • 示例剖析golang中的CSP并发模型

    示例剖析golang中的CSP并发模型

    目录 1. 相关概念: 2. CSP (通信顺序进程) 3. channel:同步&传递消息 4. goroutine:实际并发执行的实体 5. golang调度器 1. 相关概念: 用户态:当一个进程在执行用户自己的代码时处于用户运行态(用户态) 内核态:当一个进程因为系统调用陷入内核代码中执行时处于内核运行态(内核态),引入内核态防止用户态的程序随意的操作内核地址空间,具有一定的安全保护作用.这种保护模式是通过内存页表操作等机制,保证进程间的地址空间不会相互冲突,一个进程的操作不会修改另一个

  • Golang超全面讲解并发

    Golang超全面讲解并发

    目录 1. goroutine 1.1 定义 1.2 goroutine切换点 2. channel 2.1 语法 2.2 channel作为参数 2.3 channel作为返回值 2.4 chan关闭 2.5 等待goroutine 3. select 4. 传统同步机制 5. 并发模式 5.1 生成器 5.2 定义接口 5.3 非阻塞管道 5.4 超时管道 6. 广度优先算法(迷宫) 6.1 代码实现 1. goroutine 1.1 定义 func main() { for i := 0;

  • Golang基础教程之字符串string实例详解

    Golang基础教程之字符串string实例详解

    目录 1. string的定义 2.string不可变 3.使用string给另一个string赋值 4.string重新赋值 补充:字符串拼接 总结 1. string的定义 Golang中的string的定义在reflect包下的value.go中,定义如下: StringHeader 是字符串的运行时表示,其中包含了两个字段,分别是指向数据数组的指针和数组的长度. // StringHeader is the runtime representation of a string. // I

  • GoLang基础学习之go test测试

    GoLang基础学习之go test测试

    目录 1.介绍 2.函数 3.测试函数格式 3.1格式 3.2失败示例 3.3成功示例1 3.4成功示例2 3.5成功示例3 3.6成功实例4 4.基准函数 4.1成功实例1 4.2成功实例2 4.3性能比较函数 总结 1.介绍 Go语言中的测试依赖go test命令.编写测试代码和编写普通的Go代码过程是类似的,并不需要学习新的语法.规则或工具: go test 命令是go语言内置的命令 go test命令是一个按照一定约定和组织的测试代码的驱动程序在我们执行了go tets命令之后,这个命令

  • Golang WorkerPool线程池并发模式示例详解

    Golang WorkerPool线程池并发模式示例详解

    目录 正文 处理CVS文件记录 获取测试数据 线程池耗时差异 正文 Worker Pools 线程池是一种并发模式.该模式中维护了固定数量的多个工作器,这些工作器等待着管理者分配可并发执行的任务.该模式避免了短时间任务创建和销毁线程的代价. 在 golang 中,我们使用 goroutine 和 channel 来构建这种模式.工作器 worker 由一个 goroutine 定义,该 goroutine 通过 channel 获取数据. 处理CVS文件记录 接下来让我们通过一个例子,来进一步理

  • golang通过context控制并发的应用场景实现

    golang 里出现多 goroutine 的场景很常见, 最常用的两种方式就是 WaitGroup 和 Context, 今天我们了解一下 Context 的应用场景 使用场景 场景一: 多goroutine执行超时通知 并发执行的业务中最常见的就是有协程执行超时, 如果不做超时处理就会出现一个僵尸进程, 这累计的多了就会有一阵手忙脚乱了, 所以我们要在源头上就避免它们 看下面这个示例: package main import ( "context" "fmt"

  • golang基于errgroup实现并发调用的方法

    golang基于errgroup实现并发调用的方法

    目录 串行调用 基于sync.WaitGroup实现简单的并发调用 基于errgroup.Group实现并发调用 总结 串行调用 在用go编写web/rpc服务器的时候,经常会出现需要对下游多 个/组 服务调用rpc(或者其他比较耗时的操作)的情况.按照自然的写法,比如对下游有ABC三个调用,串行顺着写,就总共要花费TimeA+TimeB+TimeC的时间: func Handler(ctx context.Context) { var a, b, c respType a = A(ctx) b

随机推荐