🐶
Go语言精华(Essential Go)
  • 《Go语言基础》
  • 第一部分 语法基础
  • 01 准备开始
    • Windows安装和设置
    • macOS安装和设置
    • Linux安装和设置
    • Hello, World!
    • 来场有导游的Golang旅行
    • 离线访问文档
    • 在编程操场上运行Go
    • GOPATH, GOROOT, GOBIN
  • 02 基本类型
    • 布尔型
    • 整型
    • 浮点数
    • 字符和符号(rune)
    • 字符串
    • 常量
    • 枚举(不支持)
    • 数组
    • 切片
    • 映射
    • 结构体
    • 接口
    • 空接口
    • 指针
    • 联合体(不支持)
    • 数据通道
    • 零值
    • 类型转换
    • 类型别名
  • 03 变量(Variable)
    • 变量声明基本形式
    • 多个变量一起赋值
    • 空白标识符
  • 04 常量(Const)
    • 有类型vs无类型常量
    • iota
    • 模拟枚举
  • 05 字符串(String)
    • 在字符串中查找另一字符串
    • 字符串比较
    • 大小写转换
    • 字符串转整型和浮点型
    • 字符串修剪(删除字符或子串)
    • 字符串文本替换
    • 字符串分割和连接
    • 文本格式化
    • 文本解析
    • 逐行读取文件
    • 规范化换行符
  • 06 指针(Pointer)
    • 指针基础
    • 指针解引用(dereference)
    • 指针方法vs值方法
  • 07 数组(Array)
    • 创建数组
    • 数组索引
    • 多维数组
  • 08 切片(Slice)
    • 创建切片
    • 长度与容量
    • 追加元素
    • 切片过滤
    • 从切片删除元素
    • 复制切片
    • 零值切片
    • 切片的技巧
    • 通过预分配内存优化切片
  • 09 映射(Map)
    • 声明和初始化映射
    • 创建映射
    • 通过键获取值
    • 获取映射大小(映射条目数)
    • 拷贝一个映射
    • 用range遍历映射
    • 从映射中删除
    • 将映射(Map)用作集合(Set)
    • 以切片为值的映射
    • 并发访问映射
    • 映射的零值
  • 10 结构体(Struct)
    • 基本声明
    • 结构体字面量
    • 匿名结构体
    • 组合和嵌入
    • 可导出vs不可导出字段(公有vs私有)
    • 结构体标签
    • 复制结构体(创建一份拷贝)
    • 空结构体
    • 结构体方法
  • 11 接口(Interface)
    • 简单接口
    • 从接口检测基础类型
    • 确认某类型已实现某接口
  • 12 空接口(Empty Interface)
  • 13 if, switch, goto
    • if语句
    • switch语句
    • goto语句
  • 14 for, while循环
    • for循环的不同形式
    • break和continue
    • while循环
  • 15 range语句
    • 遍历字符串、切片、映射
    • 遍历字符串
    • 遍历切片
    • 遍历映射
    • 遍历数据通道
  • 16 函数
    • 参数
    • 返回值
    • 命名返回值
    • 可变参数函数
    • 函数字面量
    • 函数类型的变量
    • 闭包
  • 17 方法
  • 18 错误处理
    • 返回错误
    • 创建标准错误值
    • 自定义错误类型
    • 错误处理
    • 短程序中的错误处理
    • 将调用堆栈添加到错误消息
    • 编写良好的错误消息
  • 19 延迟调用(Defer)
    • 深入defer
    • defer的陷阱
  • 20 恐慌(panic)和恢复(recover)
    • 恐慌(panic)
    • 恢复(recover)
    • 从恐慌中恢复
    • 恐慌的使用场景
  • 21 并发
    • 你好,Go程
    • 创建协程
    • 等待协程结束
    • 用信号量限制并发
  • 22 数据通道(channel)和多路选择(select)
    • 使用range从channel读数据
    • 利用select为读channel设置超时
    • 关闭channel
    • 有缓冲vs无缓冲channel
    • 利用select非阻塞接收数据
    • 利用chan struct{}实现信号通道
    • 检查通道中是否有可用数据
    • channel使用惯例
  • 23 互斥锁(Mutex)
    • 读写互斥(RWMutex)
    • 互斥锁的陷阱
    • 检测竞争
  • 24 包
    • 使用go get将包安装到本地
    • 导入包
    • 创建包
    • 包初始化
    • 包命名最佳实践
  • 第二部分 常用标准库
    • 25 文件和I/O
      • 读文件
      • 写文件
      • 文件操作
      • 目录操作
      • 文件路径操作
      • I/O相关的接口
    • 26 时间和日期
      • 时间日期基本操作
      • 时间格式化
      • 时间字符串解析
      • 像strftime那样格式化时间
      • 时间和日期比较
    • 27 命令行传参
    • 28 记日志
    • 29 执行命令
    • 30 十六进制和base64编码
    • 31 JSON
    • 32 XML
    • 33 CSV
    • 34 YAML
    • 35 SQL
    • 36 HTTP客户端
      • HTTP POST
      • PUT请求发送JSON对象
    • 37 HTTP服务端
    • 38 文本和HTML模板
    • 39 反射(Reflection)
      • 原始类型
      • 指针
      • 结构体
      • 切片
      • reflect.Kind
      • 反射的用处
    • 40 上下文(Context)
      • 创建上下文
      • 用上下文为HTTP请求设置超时
      • 用上下文携带值
      • 编写可取消的函数
      • 上下文就是带值的树
      • context.TODO() vs. context.Background()
    • 41 fmt包
      • fmt基本用法
      • Stringer接口
    • 42 测试
      • 基本测试
      • 表格驱动的单元测试
      • 使用setUp和tearDown函数
      • 性能测试
      • 样例测试(自注释测试)
      • 测试HTTP请求
      • 在测试中设置/重置模拟(mock)函数
      • 以HTML格式查看代码覆盖率
    • 43 利用cgo在Go中调用C
      • cgo上手教程
      • 从Go调用C函数
      • 全方位连接C和Go代码
    • 44 使用pprof分析Go程序
      • CPU和内存基本分析
      • 使用benchmark生成分析文件
      • 内存基本分析
      • 设置CPU/Block分析速率
      • 访问分析(profile)文件
    • 45 交叉编译
    • 46 使用构建标签进行条件编译
      • 开发和生产环境编译
    • 47 内联函数
    • 48 用sync.Pool以获得更好性能
    • 49 gob
    • 50 插件机制
    • 51 HTTP服务中间件
      • 一般处理(handler)函数
      • 中间件里计算handler函数的耗时
      • CORS中间件
      • Auth中间件
      • 恢复handler以防止服务端崩溃
    • 52 Go中的Protobuf
      • 在Go中使用Protobuf
    • 53 控制台I/O
    • 54 密码学
      • 使用AES-GCM进行加密和解密
    • 55 图片处理(PNG, JPEG, BMP, TIFF, WEBP, VP8, GIF)
      • 基本概念
      • 加载和保存图片
      • 裁剪图片
      • 将图片由彩色转为灰度
      • 调整图片尺寸
    • 56 Go语言命令行工具
      • go fmt
      • go run
      • go build
      • go clean
      • go get
      • go env
      • go test
    • 57 利用持续集成(CI)服务测试代码
      • 利用Github Actions测试Go代码
    • 58 Windows图形界面(GUI)编程
      • 第一个Windows应用
  • 59 贡献者
由 GitBook 提供支持
在本页

这有帮助吗?

  1. 21 并发

你好,Go程

译者注

Goroutine在本书中均译为"Go程",意思为"Go语言例程"。之所以不翻译为协程,是因为Goroutine与Coroutine有较大区别。

一般的,协程(coroutine)都有yield或await语义的关键词,用于明确地表示协程之间的关系,谁把执行权让给谁。而Go程(goroutine)并没有相关语义的关键词,它的并发行为更像是传统的线程。

PS.当然,我们也可以基于goroutine继续封装,实现await语义。

简单地说,Linux内核调度基本单位是线程(pthreads,POSIX threads),更抽象的层次叫做内核调度实体(KSE, Kernel Scheduling Entity)或称SE(Scheduling Entity),更具体的层次的实现叫原生线程(NPTL, Native POSIX Threads Library),它们通过内核调度器进行调度。

例如Java、Python的Threads库,就是对原生线程pthreads的封装,对应关系是1:1,即1个语言级线程对应1个系统级线程,只存在1个调度级别,由系统调度器进行调度。

而像Python、JavaScript 的语言级原生Coroutine,调度对象称为协程,与内核线程的对应关系是N:1,即多个用户态协程对应1个系统级线程,协程的调度归语言标准库库实现的。以协程视角看,只存在1个调度级别,即语言级维护的用户态调度器;以语言视角看,它虽然可以感知有2个调度级别,但只用操心自己实现的协程调度器,而不用关心容纳协程的线程是如何被系统调度的;以系统视角看,只有1个调度级别,即原生线程(pthreads)的调度。

而Gevent,是对Greenlet的封装,调度对象被称为伪线程(pseudothreads),又有称绿色线程(greenlets)或微线程(micro-threads),都是一回事。内核线程与它的对应关系也是N:1,多个伪线程对应1个系统级线程。

Gevent/Greenlet的伪线程与Python原生协程的不同点在于,伪线程封装后的表现形式更像线程,伪线程之间彼此没有实现await操作,它们之间要传递数据,是通过channel/queue实现的,而且Gevent也为获取伪线程的返回值而提供了比较友好的封装,例如spawn的对象可以在wait以后get返回值,也可以通过AsyncResult对象来传递值。

Golang的Go程与内核线程的对应关系为N:M,即多对多的关系,Go程之间也通过channel传递数据(也可以通过共享内存/共享全局变量的形式,但不安全不推荐)。以Go程视角看,它只能感知到1个调度级别,即语言维护的用户态调度器;以语言视角看,存在2个调度级别(所以N:M模型又称为两级(用户态级别和系统级别)线程模型),即用户态Go程的调度,以及系统级线程在语言中的封装的对象的调度(这一级别的调度,也只是操作Go程和系统级线程对象的绑定关系,并不真正关心线程对象和CPU的绑定关系,也不关心线程对象状态的转换);以系统视角看,只存在原生线程的调度。

存在于传说中的原生高并发语言Erlang的BEAM虚拟机所实现的并发模型,比上述三种都要复杂一些。以系统角度看,Erlang程序都存在于1个进程,K个线程中(K等于CPU核数),OS操心的只是这1个进程和K个线程的调度,抢占式。以语言角度看,也是两级调度,但Erlang的封装并非是用户态线程,也不是用户态协程,更应该称用户态进程,不止因为Erlang的术语就叫他process,而是它的封装后的性质跟OS的process类似:相互隔离,不共享内存,抢占式调度。不过Erlang语言级别的process的创建和调度开销比OS级别的process小很多,process之间也通过channel传递数据。

单个通道(channel),单个协程,一个写,一个读。

package main

import (
	"fmt"
	"time"
)

func main() {
	// 创建一个用于传递string数据类型的通道
	ch := make(chan string)

	// 启动一个新的匿名协程
	go func() {
		time.Sleep(time.Second)
		// 发送 "Hello World" 到通道中
		ch <- "Hello World"
	}()
	// 从通道中读取
	msg, ok := <-ch
	fmt.Printf("msg='%s', ok='%v'\n", msg, ok)
}

// Output
// msg='Hello World', ok='true'

上面代码中的ch是无缓冲通道,又叫同步通道。

译者注

Go语言中所称的字面量函数(Function literals)就是匿名函数,它可以被赋值给变量,也可以直接调用。而且它们还可以是闭包,因为它们可能引用外部包围函数中的变量,这些变量将在包围函数和字面量函数之间共享,它们不再被访问后才会回收。

如果main()函数不阻塞等待,则协程将在main()函数结束时被杀死,该协程甚至都没有机会把数据发送到通道。

译者注

go func() 语句的作用实际上是将协程加入调度,而不是真正立刻开始执行协程代码。协程真正开始和结束的时刻并不可预测,取决于系统中协程的调度顺序和协程自身的执行耗时。

在main()结束时,所有的协程也都会被杀死,不论协程是否执行完完毕。所以要安全地结束协程,应该用无缓冲(同步)通道或sync.WaitGroup来保证协程都执行完毕。

上一页21 并发下一页创建协程

最后更新于4年前

这有帮助吗?

time.Sleep是为了解释main()函数会在ch上等待,意思是会被当做协程执行,该协程通过通道发送数据需要一点时间。<-ch会使main()函数的执行被阻塞。

字面量函数
接收操作符