有缓冲channel(管道)

左手的ㄟ右手 2023-01-08 10:28 229阅读 0赞

#### 1、有缓冲的通道（buffered channel）是指一种在被接收前能存储一个或多个值的通道。 ####

#### 2、这种类型的通道并不强制要求goroutine之间必须同时完成发送和接收，通道会阻塞发送和接收动作的条件也会不同，只有在通道中没有要接收的值时，接收动作才会阻塞，只有在通道没有在可用缓冲区容纳被发送的值时，发送动作才会阻塞。 ####

#### 3、这导致有缓冲的通道和无缓冲的通道之间的一个很大的不同，无缓冲的通保证进行发送和接收goroutine会在同一时间进行数据交换;有缓冲的通道没有这种保证。 ####

有缓冲区的channel，只是加了一个缓冲区大小 ch := make(chan int,4)

func main() { 
    	// 创建一个有缓冲区的channel，这里只是加了一个缓冲区大小
    	ch := make(chan int,4)
    
    	lenNum := 4
    
    	//len(ch)缓冲区剩余数据个数，cap(ch)缓冲区大小
    	fmt.Printf("main len(ch) = %d, cap(ch) = %d\n", len(ch), cap(ch))
    
    	// 新建协程
    	go func() { 
    		for i := 0; i < lenNum; i++ { 
    			ch <- i //往chan写内容
    			fmt.Println("子协程 i=", i)
    		}
    
    	}()
    
    	time.Sleep(2 * time.Second)
    
    	for i := 0; i < lenNum; i++ { 
    		num := <-ch  //读管道中内容，没有内容，就会阻塞
    		fmt.Printf("num = %d\n", num)
    	}
    }

运行结果如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xvbmd6aG91ZmVuZw_size_16_color_FFFFFF_t_70]

#### 4、通过上面的图可以看出，有缓存，子协程执行完成之后，才会去执行主协程 ####

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xvbmd6aG91ZmVuZw_size_16_color_FFFFFF_t_70]: /images/20221119/de04432bd8c54c839b5a9f8f85d63a7a.png