Golang语言Channel(有缓冲和无缓冲)的使用方式

import (
	"fmt"
	"time"
)

func main() {
	block := make(chan struct{})
	go odd(block)
	go even(block)
	time.Sleep(time.Second)
	fmt.Println("done")

}

func odd(block chan struct{}) {
	for i := 1; i < 100; i++ {
		<-block
		if i%2 == 1 {
			fmt.Println("奇数：", i)
		}
	}
}

func even(block chan struct{}) {
	for i := 1; i < 100; i++ {
		<-block
		if i%2 == 0 {
			fmt.Println("偶数：", i)
		}
	}
}

func main() {
	block := make(chan struct{})
	go func() {
		for i := 0; i < 10; i++ {
			fmt.Println(i)
		}
		close(block)
	}()
	<-block
	fmt.Println("done")

}

func main() {
	
	task := make(chan int, 10)
	go consumer(task)

	//生成者
	for i := 0; i < 10; i++ {
		task <- i
	}
	time.Sleep(time.Second * 2)
}

func consumer(task <-chan int) {
	for i := 0; i < 10; i++ {
		go func(id int) {
			t := <-task
			fmt.Println(id, t)
		}(i)
	}
}

import (
	"fmt"
	"time"
)

func main() {
	c1 := make(chan string, 1)
	go func() {
		time.Sleep(2 * time.Second)
		c1 <- "result 1"
	}()

	select {
	case res := <-c1:
		fmt.Println(res)
	case <-time.After(1 * time.Second):
		fmt.Println("timeout 1")
	}

	c2 := make(chan string, 1)

	go func() {
		time.Sleep(2 * time.Second)
		c2 <- "result 2"
	}()

	select {
	case res := <-c2:
		fmt.Println(res)
	case <-time.After(3 * time.Second):
		fmt.Println("timeout 1")
	}

}

func main() {
	ticker := time.NewTicker(500 * time.Millisecond)
	done := make(chan bool)
	go func() {
		for {
			select {
			case <-done:
				return
			case t := <-ticker.C:
				fmt.Println("Tick at ", t)
			}
		}
	}()
	time.Sleep(1600 * time.Millisecond)
	ticker.Stop()
	done <- true
	fmt.Println("Ticker stopped")
}