开始准备：

• 安装好 go 环境和 docker 环境的 centos7.0
  0 码力 | 5 页 | 269.19 KB | 1 年前

  3

• 基于gRPC go实现消息发布订阅

  interface{}...) { select { case sub <- v: default: // default分支为空，也就是说如果没有通道准备好接收数据，则什么也不做，程序会阻 塞在此处，直到至少有一个通道准备好为止。 } } gRPC Server启动 01. 副标题 发送端发布消息 01. 副标题 订阅端监听消息 01. 副标题
  0 码力 | 31 页 | 2.42 MB | 1 年前

  3

• Go基础语法宝典

  的值的类型。注意，必须使用 make 创建 channel ： channel 通过操作符 <- 来接收和发送数据 把这些应用到例子中来： 默认情况下， channel 接收和发送数据都是阻塞的，除非另一端已经准备好，这样就使得 Goroutines 同步变的更加的简单，而不需要显式的 lock 。所谓阻塞，也就是如果读取（ value := <-ch ）它将会 被阻塞，直到有数据接收。其次，任何发送（ ch<-5 select ，通过 select 可以监听 channel 上的数据流动。 select 默认是阻塞的，只有当监听的 channel 中有发送或接收可以进行时才会运行，当多个 channel 都准备好的时候， select 是随机的选择一个执行的。 package main import "fmt" func main() { c := make(chan int, 2)//修改2为1就报错，修改2为3可以正常运行 Println(i) } } 在 select 里面还有 default 语法， select 其实就是类似 switch 的功能， default 就是当监听的 channel 都没有准备好的时候，默认执行的（ select 不再阻塞等待 channel ）。 超时 有时候会出现 goroutine 阻塞的情况，那么如何避免整个程序进入阻塞的情况呢？可以利用 select 来
  0 码力 | 47 页 | 1020.34 KB | 1 年前

  3

• Go 入门指南(The way to Go)

  语句的初始化部分，然后进行判断： Go入门指南 - 85 - 本文档使用 看云 构建 习惯用法 if value, ok := readData(); ok { … } 注意事项 如果您像下面一样，没有为多返回值的函数准备足够的变量来存放结果： func mySqrt(f float64) (v float64, ok bool) { if f < 0 { return } // error case O_WRONLY, 0) 我们不使用缓冲区，直接将内容写入文件： f.WriteString( ) 练习 12.4：wiki_part1.go （这是一个独立的练习，但是同时也是为章节15.4做准备） 程序中的数据结构如下，是一个包含以下字段的结构: type Page struct { Title string Body []byte } 请给这个结构编写一个 save 默认情况下，通信是同步且无缓冲的：在有接受者接收数据之前，发送不会结束。可以想象一个无缓冲的 通道在没有空间来保存数据的时候：必须要一个接收者准备好接收通道的数据然后发送者可以直接把数据 发送给接收者。所以通道的发送/接收操作在对方准备好之前是阻塞的： 1）对于同一个通道，发送操作（协程或者函数中的），在接收者准备好之前是阻塞的：如果ch中的数据无 人接收，就无法再给通道传入其他数据：新的输入无法在通道非空的情况下传入。所以发送操作会等待
  0 码力 | 380 页 | 2.97 MB | 1 年前

  3

• Go 入门指南(The way to Go)

  if 语句的初始化部分，然后进行判断： 习惯用法 1. if value, ok := readData(); ok { 2. … 3. } 注意事项 如果您像下面一样，没有为多返回值的函数准备足够的变量来存放结果： 1. func mySqrt(f float64) (v float64, ok bool) { 2. if f < 0 { return } // error case WriteString( ) 练习 12.4：wiki_part1.go 12.2 文件读写 - 324 - 本文档使用 书栈(BookStack.CN) 构建 （这是一个独立的练习，但是同时也是为章节15.4做准备） 程序中的数据结构如下，是一个包含以下字段的结构: 1. type Page struct { 2. Title string 3. Body []byte 4. } 默认情况下，通信是同步且无缓冲的：在有接受者接收数据之前，发送不会结束。可以想象一个无缓冲的通道在没有 空间来保存数据的时候：必须要一个接收者准备好接收通道的数据然后发送者可以直接把数据发送给接收者。所以通 道的发送/接收操作在对方准备好之前是阻塞的： 1）对于同一个通道，发送操作（协程或者函数中的），在接收者准备好之前是阻塞的：如果ch中的数据无人接收，就 14.2.3 通道阻塞 14.2 协程间的信道 - 385 -
  0 码力 | 466 页 | 4.44 MB | 1 年前

  3

• 可视化学习 Go 并发编程

  go func() { time.Sleep(deltaT) timerChan <- time.Now() // 将时间发送给timerChan }() // 做一些其它事情；准备接收 // 接收会阻塞，直到 timerChan 传送值 // 值的发送是另上个 goroutine 结束的时间 completedAt := <-timerChan Select 类似于
  0 码力 | 29 页 | 1.48 MB | 1 年前

  3

• Golang 101(Go语言101 中文版) v1.21.a

  上面已经提到过，一旦一个非零通道被关闭，继续向此通道发送数据将产生一 个恐慌。 注意，向关闭的通道发送数据属于一个非阻塞操作。 通道操作情形C： 当一个协程成功获取到一个非零且尚未关闭的通道的锁并且 准备关闭此通道时，下面两步将依次执行： 1. 如果此通道的接收数据协程队列不为空（这种情况下，缓冲队列必为 空），此队列中的所有协程将被依个弹出，并且每个协程将接收到此通道 的元素类型的一个零值，然后恢复至运行状态。 func() { 18 | if v := recover(); v != nil { // 侦测到一个恐慌 19 | log.Printf("协程%s崩溃了，准备重启一个", name) 20 | go NeverExit(name, f) // 重启一个同功能协程 21 | } 22 | }() 23 | 返回单向接收通道做为函数返回结果 在下面这个例子中，sumSquares函数调用的两个实参请求并发进行。 每个通 道读取操作将阻塞到请求返回结果为止。 两个实参总共需要大约3秒钟（而不 是6秒钟）准备完毕（以较慢的一个为准）。 1| package main 2| 3| import ( 4| "time" 5| "math/rand" 6| "fmt" 7| ) 8| 9|
  0 码力 | 821 页 | 956.82 KB | 1 年前

  3

• Golang 101(Go语言101 中文版) v1.21.a

  上面已经提到过，一旦一个非零通道被关闭，继续向此通道发送数据将产生一 个恐慌。 注意，向关闭的通道发送数据属于一个非阻塞操作。 通道操作情形C： 当一个协程成功获取到一个非零且尚未关闭的通道的锁并且 准备关闭此通道时，下面两步将依次执行： 1. 如果此通道的接收数据协程队列不为空（这种情况下，缓冲队列必为 空），此队列中的所有协程将被依个弹出，并且每个协程将接收到此通道 的元素类型的一个零值，然后恢复至运行状态。 func()) { defer func() { if v := recover(); v != nil { // 侦测到一个恐慌 log.Printf("协程%s崩溃了，准备重启一个", name) go NeverExit(name, f) // 重启一个同功能协程 } }() f() } func main() { log 返回单向接收通道做为函数返回结果 在下面这个例子中，sumSquares函数调用的两个实参请求并发进行。 每个通道 读取操作将阻塞到请求返回结果为止。 两个实参总共需要大约3秒钟（而不是6 秒钟）准备完毕（以较慢的一个为准）。 package main import ( "time" "math/rand" "fmt" ) func longTimeRequest() <-chan
  0 码力 | 608 页 | 1.08 MB | 1 年前

  3

• Golang 101(Go语言101 中文版) v1.21.a

  上面已经提到过，一旦一个非零通道被关闭，继续向此通道发送数据将产生一个恐 慌。 注意，向关闭的通道发送数据属于一个非阻塞操作。 通道操作情形C： 当一个协程成功获取到一个非零且尚未关闭的通道的锁并且准备 关闭此通道时，下面两步将依次执行： 1. 如果此通道的接收数据协程队列不为空（这种情况下，缓冲队列必为空），此 队列中的所有协程将被依个弹出，并且每个协程将接收到此通道的元素类型的 一个零值，然后恢复至运行状态。 defer func() { 18| if v := recover(); v != nil { // 侦测到一个恐慌 19| log.Printf("协程%s崩溃了，准备重启一个", name) 20| go NeverExit(name, f) // 重启一个同功能协程 21| } 22| }() 23| f() 返回单向接收通道做为函数返回结果 在下面这个例子中，sumSquares函数调用的两个实参请求并发进行。 每个通道读 取操作将阻塞到请求返回结果为止。 两个实参总共需要大约3秒钟（而不是6秒钟） 准备完毕（以较慢的一个为准）。 1| package main 2| 3| import ( 4| "time" 5| "math/rand" 6| "fmt" 7|
  0 码力 | 591 页 | 21.40 MB | 1 年前

  3