package main
func main() {
	var chan1 = make(chan int)
	var chan2 = make(chan int)
	select {
	case <-chan1:
		// 如果chan1成功讀到數(shù)據(jù)，則進行該case處理語句
	case chan2:
		// 如果chan2成功讀到數(shù)據(jù)，則進行該case處理語句
	default:
		// 如果上面都沒有成功，則進行該case處理語句
	}
}

//fibonacci     1 1 2 3 5 8
package main
import (
	"fmt"
)
//ch只寫，quit只讀
func fibonacci(ch chan<- int, quit <-chan bool) {
	x, y := 1, 1
	for {
		//監(jiān)聽channel數(shù)據(jù)的流動
		select {
		case ch <- x:
			x, y = y, x+y
		case flag := <-quit:
			fmt.Println("flag = ", flag)
			return
		}
	}
}
func main() {
	ch := make(chan int)    //數(shù)字通信
	quit := make(chan bool) //程序是否結束

	//消費者，從channel讀取內(nèi)容
	//新建協(xié)程
	go func() {
		for i := 0; i < 8; i++ {
			num := <-ch
			fmt.Println(num)
		}
		//可以停止
		quit <- true
	}() //別忘了()
	//生產(chǎn)者，產(chǎn)生數(shù)字，寫入channel
	fibonacci(ch, quit)

}


1
1
2
3
5
8
13
21
flag =  true

func main()  {
	//創(chuàng)建一個有緩存的channel
	ch := make(chan int, 0)
	//len(ch)緩沖區(qū)剩余數(shù)據(jù)個數(shù)， cap(ch)緩沖區(qū)大小
	//新建協(xié)程
	go func() {
		for i := 0; i < 10; i++ {
			ch <- i //往chan寫內(nèi)容
		}
	}()
	ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
	go func(ctx context.Context) {
		ticker := time.NewTicker(1 * time.Second)
		for _ = range ticker.C {
			select {
			case <-ctx.Done():
				fmt.Println("child process interrupt...")
				return
			default:
				fmt.Printf("send message: %d\n", <-ch)
			}
		}
	}(ctx)
	defer close(ch)
	defer cancel()
	select {
	case <-ctx.Done():
		time.Sleep(1 * time.Second)
		fmt.Println("main process exit!")
	}
}