go语言实现多个goroutine之间通信

package main

import "fmt"

func main() {
	// 创建一个 channel
	c := make(chan int)

	go func() {
		defer fmt.Println("goroutine结束！")

		fmt.Println("goroutine正在运行")
		// 将数据发送到 channel 中
		c <- 100
	}()

	// 从 channel 中接收数据, 存入到 num
	num := <- c

	fmt.Println("num:", num)
	fmt.Println("main goroutine 结束")
}

package main

import (
	"fmt"
	"time"
)

func main() {
	// 创建一个容量为3的 channel（有缓冲的channel）
	c := make(chan int, 3)

	go func() {
		defer fmt.Println("子go程结束！")

		for i := 0; i < 3; i++ {
			c <- i
			fmt.Println("子go程 i = ", i, "  元素个数：", len(c), "  元素个数：", cap(c))
		}	
	}()

	time.Sleep(1 * time.Second)

	for i := 0; i < 3; i++ {
		// 从 channel 中获取数据
		num := <- c
		fmt.Println("num =", num)
	}

	fmt.Println("main goroutine 运行结束")

}

package main

import "fmt"

func main() {
	c := make(chan int)

	go func() {
		for i := 0; i < 3; i++ {
			c <- i
		}

		// close 关闭 channel
		close(c)
	}()

	for {
		// ok 为 true 表示 channel 没有关闭, ok 为 false 表示 channel 已经关闭
		if data, ok := <- c; ok {
			fmt.Println("data: ", data) 
		} else {
			break
		}
	}

	fmt.Println("main goroutine 结束")

}

package main

import "fmt"

func main() {
	c := make(chan int)

	go func() {
		for i := 0; i < 3; i++ {
			c <- i
		}

		// close 关闭 channel
		close(c)
	}()

	/* for {
		// ok 为 true 表示 channel 没有关闭, ok 为 false 表示 channel 已经关闭
		if data, ok := <- c; ok {
			fmt.Println("data: ", data) 
		} else {
			break
		}
	} */

	// 可以使用 range 代替不断迭代的操作的cahnnel
	for data := range c {
		fmt.Println("data: ", data)
	}

	fmt.Println("main goroutine 结束")

}

package main

import (
	"fmt"
)

func method(c, quit chan int) {
	x, y := 1, 1

	for {
		select {
		case c <- x:
			// 如果 c 可写入，执行下面
			x = y
			y = x + y
		case <- quit:
			fmt.Println("quit.....")
			return 
		}
	}
}

func main() {
	c := make(chan int)
	quit := make(chan int)

	go func() {
		for i := 0; i < 6; i++ {
			fmt.Println(<-c)
		}

		quit <- 0
	}()

	method(c, quit)
}