1.信道，就是一個(gè)管道，連接多個(gè)goroutine程序 殷勘，它是一種隊(duì)列式的數(shù)據(jù)結(jié)構(gòu)，遵循先入先出的規(guī)則昔搂。
package main
import (
"fmt"
"time"
)
func chaninit() {
// 定義 信道實(shí)例 := make(chan 信道類(lèi)型)
ch := make(chan int, 10)
// 信道的容量和長(zhǎng)度
fmt.Println(cap(ch))
ch <- 12
fmt.Println(len(ch))
}
func increment(ch chan bool, x *int) {
ch <- true
*x = *x + 1
<-ch
}
func test_incr() {
// 注意要設(shè)置容量為 1 的緩沖信道
pipline := make(chan bool, 1)
var x int
for i := 0; i < 1000; i++ {
go increment(pipline, &x)
}
// 確保所有的協(xié)程都已完成
// 以后會(huì)介紹一種更合適的方法（Mutex）玲销，這里暫時(shí)使用sleep
fmt.Println("x 的值：0000", x)
time.Sleep(time.Second)
fmt.Println("x 的值：", x)
}
func for_test() {
pipeline := make(chan int)
go func() {
pipeline <- 100
}()
go func() {
num := <-pipeline
fmt.Println("receive", num)
}()
}
func main() {
test_incr()
time.Sleep(10 * time.Second)
}
package main
import (
"fmt"
"sync"
)
func test001() {
ch := make(chan bool)
go func() {
for i := 0; i < 5; i++ {
fmt.Println(i)
}
ch <- true
}()
<-ch
}
func worker(x int, wg *sync.WaitGroup) {
defer wg.Done()
for i := 0; i < 500; i++ {
fmt.Println(i)
}
}
func test002() {
var wg sync.WaitGroup
wg.Add(2)
go worker(1, &wg)
go worker(2, &wg)
wg.Wait()
}
func main() {
test001()
test002()
}
