共计 2413 个字符，预计需要花费 7 分钟才能阅读完成。
- 根本应用
| package main | |
| import ( | |
| "fmt" | |
| "sync" | |
| ) | |
| var wg sync.WaitGroup | |
| func hello() {fmt.Println("hello func...") | |
| wg.Done() // 告诉计数器减 1} | |
| func main() {wg.Add(4) // 计数器，4 个并发工作 | |
| go hello() | |
| go hello() | |
| go hello() | |
| go hello() | |
| fmt.Println("main func!") | |
| wg.Wait() // 期待所有工作执行实现} |
- 革新一下，开启 10000 个 goroutine
| package main | |
| import ( | |
| "fmt" | |
| "sync" | |
| ) | |
| var wg sync.WaitGroup | |
| func hello(i int) {fmt.Println("hello func...", i) | |
| wg.Done()} | |
| func main() {// wg.Add(10000) | |
| for i := 0; i < 10000; i++ {wg.Add(1) | |
| go hello(i) | |
| } | |
| fmt.Println("main func!") | |
| wg.Wait()} |
- 将上一个例子革新成匿名函数
| package main | |
| import ( | |
| "fmt" | |
| "sync" | |
| ) | |
| var wg sync.WaitGroup | |
| func main() {// wg.Add(10000) | |
| for i := 0; i < 10000; i++ {go func(i int) {fmt.Println("hello...", i) | |
| }(i) | |
| } | |
| fmt.Println("main func!") | |
| wg.Wait()} |
- 指定占用 CPU 外围数
| package main | |
| import ( | |
| "fmt" | |
| "runtime" | |
| "sync" | |
| ) | |
| var wg sync.WaitGroup | |
| func test1() { | |
| for i := 0; i < 10; i++ {fmt.Println("func test1...", i) | |
| } | |
| } | |
| func test2() { | |
| for i := 0; i < 10; i++ {fmt.Println("func test2...", i) | |
| } | |
| } | |
| func main() {runtime.GOMAXPROCS(1) // 只占用 1 个 CPU 外围 | |
| wg.Add(2) | |
| go test1() | |
| go test2() | |
| wg.Wait()} |
- 带缓冲区的通道，相似于异步的操作
| package main | |
| import "fmt" | |
| func main() {ch1 := make(chan int, 1) // 只能寄存 1 个值的缓冲区通道 | |
| ch1 <- 10 // 发送 | |
| x := <-ch1 // 接管 | |
| fmt.Println(x) | |
| close(ch1) | |
| } |
- 无缓冲区的通道，又称为同步通道
| package main | |
| import "fmt" | |
| func main() {ch1 := make(chan int) // 无缓冲区通道，又称为同步通道，ch1 <- 10 // 此时这里会处于阻塞的状态，除非有另外一个 goroutine 去取值，它才会发送 | |
| x := <-ch1 | |
| fmt.Println(x) | |
| close(ch1) | |
| } |
- 获取通道的容量和通道里的元素数量
| package main | |
| import "fmt" | |
| func main() {ch1 := make(chan int, 10) | |
| ch1 <- 89 | |
| ch1 <- 70 | |
| fmt.Println(len(ch1)) // 获取通道中元素的数量 | |
| fmt.Println(cap(ch1)) // 获取通道的容量 | |
| close(ch1) | |
| } |
- 通道和 goroutine 的小栗子
| package main | |
| import ( | |
| "fmt" | |
| "sync" | |
| ) | |
| type myinterface interface{} | |
| var ch1 = make(chan myinterface, 1) | |
| var wg sync.WaitGroup | |
| func sendData(i myinterface) {fmt.Printf("向通道发送 %v 胜利 \n", i) | |
| ch1 <- i | |
| wg.Done()} | |
| func readData() { | |
| v := <-ch1 | |
| fmt.Println("从通道获取的值：", v) | |
| wg.Done()} | |
| func main() {nameArray := []string{"ttr", "tantianran"} | |
| wg.Add(2) | |
| go sendData(nameArray) | |
| go readData() | |
| wg.Wait()} |
- 通道 +goroutine，实现协同干活例子 2
| package main | |
| import "fmt" | |
| func producer(ch chan int) { | |
| for i := 0; i < 10; i++ {ch <- i} | |
| close(ch) | |
| } | |
| func consumer(ch1 chan int, ch2 chan int) { | |
| for { | |
| v, ok := <-ch1 | |
| if !ok {break} | |
| ch2 <- v * 2 | |
| } | |
| close(ch2) | |
| } | |
| func main() {ch1 := make(chan int, 100) | |
| ch2 := make(chan int, 200) | |
| go producer(ch1) | |
| go consumer(ch1, ch2) | |
| for i := range ch2 {fmt.Println(i) | |
| } | |
| } |
本文转载于（喜爱的盆友关注咱们哦）：https://mp.weixin.qq.com/s/_X…
正文完
