out all running goroutines ● Before the unit test runs, remembers all running goroutines ● After the unit test is finished, if there are any new goroutines, that are leaked goroutines func TestT(t *testing

fmt.Println(s) } } func main() { go say("world") //开一个新的Goroutines执行 say("hello") //当前Goroutines执行 } // 以上程序执行后将输出： // hello // world // hello // world // hello // world channel ： channel 通过操作符 <- 来接收和发送数据 把这些应用到例子中来： 默认情况下， channel 接收和发送数据都是阻塞的，除非另一端已经准备好，这样就使得 Goroutines 同步变的更加的简单，而不需要显式的 lock 。所谓阻塞，也就是如果读取（ value := <-ch ）它将会 被阻塞，直到有数据接收。其次，任何发送（ ch<-5 ）将会被阻塞，直到数据被读出。无缓冲 1 c <- 2 fmt.Println(<-c) fmt.Println(<-c) } //修改为1报如下的错误: //fatal error: all goroutines are asleep - deadlock! package main import ( "fmt" ) func fibonacci(n int, c chan int)

，这个方法确保被调用函数只能被调用一次。 相对简单的情况下，通过使用 sync 包可以解决同一时间只能一个线程访问变量或 map 类型数据的问题。 如果这种方式导致程序明显变慢或者引起其他问题，我们要重新思考来通过 goroutines 和 channels 来解 决问题，这是在 Go 语言中所提倡用来实现并发的技术。我们将在第 14 章对其深入了解，并在第 14.7 节 中对这两种方式进行比较。 Go入门指南 - 对象的字段（属性）不应该由 2 个或 2 个以上的不同线程在同一时间去改变。如果在程序发生这种情况， 为了安全并发访问，可以使用包 sync （参考第 9.3 节）中的方法。在第 14.17 节中我们会通过 goroutines 和 channels 探索另一种方式。 10.6.5 内嵌类型的方法和继承 当一个匿名类型被内嵌在结构体中时，匿名类型的可见方法也同样被内嵌，这在效果上等同于外层类型 继 承 了这些 1000000），并展示 N 的值和函数执行的平均时间，单位为 ns（纳秒，ns/op）。如果是用 testing.Benchmark 调用这些函数，直接运行程序即可。 具体可以参见 14.16 节中用 goroutines 运行基准测试的例子以及练习 13.4：string_reverse_test.go 13.8 测试的具体例子 在练习 9.4 中你写了一个叫 main_oddeven.go 的程序用来测试前

，这个方法确保被调用函数只能被调用一次。 相对简单的情况下，通过使用 sync 包可以解决同一时间只能一个线程访问变量或 map 类型数据的问题。如果这种 方式导致程序明显变慢或者引起其他问题，我们要重新思考来通过 goroutines 和 channels 来解决问题，这是 在 Go 语言中所提倡用来实现并发的技术。我们将在第 14 章对其深入了解，并在第 14.7 节中对这两种方式进行 比较。 9.3 锁和 sync 对象的字段（属性）不应该由 2 个或 2 个以上的不同线程在同一时间去改变。如果在程序发生这种情况，为了安全 并发访问，可以使用包 sync （参考第 9.3 节）中的方法。在第 14.17 节中我们会通过 goroutines 和 channels 探索另一种方式。 当一个匿名类型被内嵌在结构体中时，匿名类型的可见方法也同样被内嵌，这在效果上等同于外层类型 继承 了这些 方法：将父类型放在子类型中来实现亚型 1000000），并展示 N 的值和函数执行的平均时间，单位为 ns（纳秒，ns/op）。如果是用 testing.Benchmark 调用这些函数，直接运行程序即可。 具体可以参见 14.16 节中用 goroutines 运行基准测试的例子以及练习 13.4：string_reverse_test.go 目录 上一节：启动外部命令和程序 下一节：测试的具体例子 链接 13.7 Go 中的单元测试和基准测试

// f 运行; 等待 go f("hello", "world") // f 开始运行 g() // 不用等待 f 返回 Channel 类似于 UNIX 中的 管道 允许在 goroutines 之间传递消息 timerChan := make(chan time.Time) go func() { time.Sleep(deltaT) timerChan <- org/2012/concurrency.slide#39) 中有提到 Go并发可视化 (/2017/go-concurrency-visualize/primesieve.html) 5. 其它-Goroutines 泄露 func leaker() { time.Sleep(1000000 * time.Minute) } func main() { trace.Start(os

Gosched() fmt.Println(s) } } func main() { go say("world") //开一个新的Goroutines执行 say("hello") //当前Goroutines执行 } 输出： hello world hello world hello world hello world hello 我们可以看到go关键字很方便的就实现了并发编程。 // receive from c fmt.Println(x, y, x + y) } 默认情况下，channel接收和发送数据都是阻塞的，除非另一端已经准备好，这样就使得Goroutines同步变的更加的 简单，而不需要显式的lock。所谓阻塞，也就是如果读取（value := <-ch）它将会被阻塞，直到有数据接收。其 次，任何发送（ch<-5）将会被阻塞，直到数据被读出。无 Go的http有两个核心功能：Conn、ServeMux Conn的goroutine Conn的goroutine 与我们一般编写的http服务器不同, Go为了实现高并发和高性能, 使用了goroutines来处理Conn的读写事件, 这样每 个请求都能保持独立，相互不会阻塞，可以高效的响应网络事件。这是Go高效的保证。 Go在等待客户端请求里面是这样写的： c, err := srv.newConn(rw)

goroutine; P - logical processor; M - OS thread (machine) • 缓存友好 • NUMA友好 • 调度的公平性 • 通信/⾮非通信goroutines的分布 • 计时器和network poller的分布 • 让poll network跟上⼀一次读在相同核上 ⼤大纲 • 并发 • 接⼝口 • 垃圾回收 • 调度

Summary •Goroutine is great for concurrency programming. •Channel used for coordination between goroutines. •State machine pattern simplifies the implementation of control flow. •Try it, love it and contribute

对gc造成的延迟(几十ms)不敏感 多说一句Go 1.5/1.6：没有银弹 • Stop-The-World(STW)缩短了，决定因素也变了 –Time spent looping over goroutines –Time spent looping over malloc spans • 实际运行，还是有几十个ms的STW时间 –GO-BFE的场景和服务模式，大量的goroutine必然 存在

如何消除程序中的数据竞争 周光远 华为 从一些问题说起 1 2 3 什么是数据竞争 Go语言中的数据竞争（data race）： data race occurs when two goroutines access the same variable concurrently and at least one of the accesses is a write. 数据竞争（data