Go语言入门14（channel通道01）

channel（一）

​ channel用于goroutines之间的通信，让它们之间可以进行数据交换。像管道一样，一个goroutine_A向channel_A中放数据，另一个goroutine_B从channel_A取数据

channel 基本语法

// 因为channel是指针类型的数据类型，所以通过make来分配内存
// 使用make声明一个channel，里面可以存放string类型的数据
channel := make(chan string)
// 将tmp送到channel中
channel <- tmp
// 从channel中接受数据给tmp
tmp := <- channel
// 从channel中接受数据给tmp，如果没有接受到则ok值为false
tmp,ok := <- channel
// 关闭通道channel
close(channel)

无缓冲的通道

​ 没有缓冲的通道，如果routine A向通道中发送了一个数据，那么必须等到这个数据被其他routine 取出之后，才能继续往通道里发送，严格遵循”一进一出“原则，这也就要求两个routine 在同时对同一个通道进行写操作和取操作

• sender端向channel中send一个数据，然后阻塞，直到receiver端将此数据receive
• receiver端一直阻塞，直到sender端向channel发送了一个数据

// 两个routine分别对一个通道进行取放操作，并且对里面的数据+1，到2000截至
// 严格遵循“一进一出”
func Routine01(wg *sync.WaitGroup, count chan int) {
	defer wg.Done()
	for {
        // 从通道中拿取数据
		res, ok := <-count
		if !ok {
            // 说明通道中已经没有数据，或者已被关闭
			fmt.Println("finish!")
			break
		}
		fmt.Println(res)
		if res == 2000 {
			close(count)
			break
		}
		count <- res + 1
	}
}

func main() {
	var wg sync.WaitGroup
    // 新建一个无缓冲的通道count
	count := make(chan int)
	wg.Add(2)
    // 创建两个协程
	for i := 0; i < 2; i++ {
		go Routine01(&wg, count)
	}
    // 给管道里送一个数据，来开始操作
	count <- 1
	wg.Wait()
}

有缓冲的通道

​ 有缓冲的通道，可以控制里面的缓冲区大小，可以借助通道实现异步的取放操作

• 容量：表示buffered channel最多可以缓冲多少个数据
• 长度：表示buffered channel当前已缓冲多少个数据
• 创建buffered channel的方式为make(chan TYPE,CAP)

// 新建Routine来模拟机器人工作
func Routine02(wg *sync.WaitGroup, count chan string) {
	defer wg.Done()
	for {
        // 从通道中分配工作
		tmp, ok := <-count
		if !ok {
            // 代表通道已经空了，或者已被关闭
			fmt.Println("No task else!")
			break
		}
		fmt.Println(tmp + " start!")
		time.Sleep(200 * time.Millisecond)
		fmt.Println(tmp + " done!")
	}
}

func main() {
	var wg sync.WaitGroup
    // 新建一个缓冲区大小为5的通道，来管理工作
	count := make(chan string, 5)
	wg.Add(2)
	fmt.Println("Work start!")
    // 往缓冲区中放一系列待完成的工作
	for i := 0; i < 5; i++ {
		tmp := fmt.Sprintf("Task %d", i)
		count <- tmp
		fmt.Println(tmp + " in!")
	}
	for i := 0; i < 2; i++ {
		go functions.Routine(&wg, count)
	}
    // 关闭通道
	close(count)
	wg.Wait()
}