|
|
@@ -11,16 +11,21 @@
|
|
|
|
|
|
如果使用通道传递大量单独的数据,那么通道将变成你的性能瓶颈。然而,当将数据块打包封装成数组,在接收端解压数据时,性能可以提高至10倍。
|
|
|
|
|
|
+
|
|
|
创建:`ch := make(chan type, buf)`
|
|
|
|
|
|
- (1)如何使用for或者for-range遍历一个通道:
|
|
|
+
|
|
|
+ (1)如何使用`for`或者`for-range`遍历一个通道:
|
|
|
+
|
|
|
+
|
|
|
```go
|
|
|
for v := range ch {
|
|
|
// do something with v
|
|
|
}
|
|
|
```
|
|
|
|
|
|
- (2)如何检测一个通道ch是否是关闭的:
|
|
|
+ (2)如何检测一个通道`ch`是否是关闭的:
|
|
|
+
|
|
|
|
|
|
```go
|
|
|
//read channel until it closes or error-condition
|
|
|
@@ -47,8 +52,10 @@ doSomethingElseForAWhile()
|
|
|
<-ch // Wait for goroutine to finish; discard sent value.
|
|
|
```
|
|
|
|
|
|
+
|
|
|
如果希望程序必须一直阻塞,在匿名函数中省略 `ch <- 1`即可。
|
|
|
|
|
|
+
|
|
|
(4)通道的工厂模板:下面的函数是一个通道工厂,启动一个匿名函数作为协程以生产通道
|
|
|
|
|
|
```go
|
|
|
@@ -69,7 +76,9 @@ func pump() chan int {
|
|
|
|
|
|
(7)如何在多核CPU上实现并行计算:参考14.13小节
|
|
|
|
|
|
- (8)如何停止一个协程:`runtime.Goexit()`
|
|
|
+
|
|
|
+ (8)如何停止一个协程:`runtime.Goexit()`
|
|
|
+
|
|
|
|
|
|
(9)简单的超时模板:
|
|
|
|