modified: eBook/18.1.md

modified:   eBook/18.11.md
	modified:   eBook/18.2.md
	modified:   eBook/18.3.md
	modified:   eBook/18.4.md
	modified:   eBook/18.8.md
This commit is contained in:
songleo
2016-01-03 14:29:25 +08:00
parent 34534d240c
commit 0aefb4a032
6 changed files with 52 additions and 61 deletions

View File

@@ -1,22 +1,20 @@
# 18.8 协程goroutine与通道channel
出于性能考虑的建议:
出于性能考虑的建议:
实践经验表明,如果你使用并行性获得高于串行运算的效率:在协程内部已经完成的大部分工作,其开销比创建协程和协程间通信还高。
实践经验表明,如果你使用并行性获得高于串行运算的效率:在协程内部已经完成的大部分工作,其开销比创建协程和协程间通信还高。
1 出于出于性能考虑建议使用带缓存的通道:
使用带缓存的通道很轻易成倍提高它的吞吐量某些场景其性能可以提高至10倍甚至更多。通过调整通道的容量你可以尝试着更进一步的优化其的性能。
1 出于出于性能考虑建议使用带缓存的通道:
2 限制一个通道的数据数量并将它们封装在成一个数组:
使用带缓存的通道很轻易成倍提高它的吞吐量某些场景其性能可以提高至10倍甚至更多。通过调整通道的容量你可以尝试着更进一步的优化其的性能。
如果使用通道传递大量单独的数据那么通道将变成你的性能瓶颈。然而当将数据块打包封装成数组在接收端解压数据时性能可以提高至10倍。
2 限制一个通道的数据数量并将它们封装在成一个数组:
如果使用通道传递大量单独的数据那么通道将变成你的性能瓶颈。然而当将数据块打包封装成数组在接收端解压数据时性能可以提高至10倍。
创建:`ch := make(chan type, buf)`
1如何使用`for`或者`for-range`遍历一个通道:
创建:`ch := make(chan type, buf)`
1如何使用`for`或者`for-range`遍历一个通道:
```go
for v := range ch {
@@ -24,8 +22,7 @@ for v := range ch {
}
```
2如何检测一个通道`ch`是否是关闭的:
2如何检测一个通道`ch`是否是关闭的:
```go
//read channel until it closes or error-condition
@@ -37,10 +34,11 @@ for {
}
```
或者使用1自动检测。
或者使用1自动检测。
3如何通过一个通道让主程序等待直到协程完成
(信号量模式):
3如何通过一个通道让主程序等待直到协程完成
(信号量模式):
```go
ch := make(chan int) // Allocate a channel.
// Start something in a goroutine; when it completes, signal on the channel.
@@ -52,11 +50,9 @@ doSomethingElseForAWhile()
<-ch // Wait for goroutine to finish; discard sent value.
```
如果希望程序必须一直阻塞,在匿名函数中省略 `ch <- 1`即可。
如果希望程序必须一直阻塞,在匿名函数中省略 `ch <- 1`即可。
4通道的工厂模板下面的函数是一个通道工厂启动一个匿名函数作为协程以生产通道
4通道的工厂模板下面的函数是一个通道工厂启动一个匿名函数作为协程以生产通道
```go
func pump() chan int {
@@ -70,17 +66,15 @@ func pump() chan int {
}
```
5通道迭代器模板
6如何限制并发处理请求的数量参考14.11小节
7如何在多核CPU上实现并行计算参考14.13小节
5通道迭代器模板
6如何限制并发处理请求的数量参考14.11小节
7如何在多核CPU上实现并行计算参考14.13小节
(8)如何停止一个协程:`runtime.Goexit()`
9简单的超时模板
(8)如何停止一个协程:`runtime.Goexit()`
9简单的超时模板
```go
timeout := make(chan bool, 1)
@@ -96,7 +90,7 @@ select {
}
```
10如何使用输入通道和输出通道代替锁
10如何使用输入通道和输出通道代替锁
```go
func Worker(in, out chan *Task) {
@@ -108,11 +102,11 @@ func Worker(in, out chan *Task) {
}
```
11如何在同步调用运行时间过长时将之丢弃参考14.5小节 第二个变体
11如何在同步调用运行时间过长时将之丢弃参考14.5小节 第二个变体
12如何在通道中使用计时器和定时器参考14.5小节
12如何在通道中使用计时器和定时器参考14.5小节
13典型的服务器后端模型参考14.4小节
13典型的服务器后端模型参考14.4小节
## 链接