go笔记--缓冲channel简单使用

短命女 2021-12-22 23:34 251阅读 0赞

# golang的缓冲channel简单使用 #

### 文章目录 ###

*  golang的缓冲channel简单使用
 *   *   *  阻塞型
         *  非阻塞

--------------------

我们常用的是无缓冲channel :

make(chan type)

无缓冲通道channel必须在接受方与发送方同时准备好时，通道才能正常传递数据，否则双方只有一方在线都会阻塞。

而有缓冲的通道，可以放入缓冲预设大小的数据不会阻塞满了后才会阻塞， 注意下两者的区别。

`make(chan type) != make(chan type, 1)`

下面简单测试有缓冲channel的两个例子.

### 阻塞型 ###

demo :  
协程1 :每隔1s 往有10个缓冲的channel里面写一条msg,

协程2:每隔3s 取一条msg,

package main 
    
    import(
    	//"fmt"
    	"time"
    	"strconv"
    	log "github.com/astaxie/beego/logs"
    )
    
    func main() {
        
    	log.Debug("---main--- start")
    
    	msgs := make(chan string, 10)
    
    	i := 0
    
    	go func() {
        
    		time.Sleep(3*time.Second)
    
    		for {
        
    			time.Sleep(1*time.Second)
    			i++
    			msg := "msg " + strconv.Itoa(i)
    			msgs <- msg
    			log.Debug("------ put msg : ", msg)
    		}
    	}()
    
    	go func() {
        
    
    		for {
        
    
    			get := <- msgs
    
    			log.Debug("---------------- pop msg : ", get)
    
    			time.Sleep(3*time.Second)
    		}
    
    	}()
    
    	time.Sleep(100*time.Second)
    
    }

可以看到当缓冲区满了以后，写channel的操作会阻塞在那里等待读端取走msg后才能写入。

![image.png][]

### 非阻塞 ###

实际场景中我们可能不希望程序阻塞，那么可以使用select来控制，当缓冲区满了后忽略该条msg继续执行我们的程序。

package main 
    
    import(
    	//"fmt"
    	"time"
    	"strconv"
    	log "github.com/astaxie/beego/logs"
    )
    
    func main() {
        
    	log.Debug("---main--- start")
    
    	msgs := make(chan string, 3)
    
    	i := 0
    
    	go func() {
        
    		time.Sleep(3*time.Second)
    
    		for {
        
    
    			time.Sleep(1*time.Second)
    			i++
    			msg := "msg " + strconv.Itoa(i)
    
    			select {
        
    				case msgs <- msg:
    					log.Debug("------ put msg : ", msg)
    				default :
    					log.Debug("-----msgs chan cache full sleep 1s-----")
    					log.Debug("-----ignore this msg-----> : ", msg)
    			}
    		}
    	}()
    
    	go func() {
        
    
    		for {
        
    
    			get := <- msgs
    
    			log.Debug("---------------- pop msg : ", get)
    
    			time.Sleep(3*time.Second)
    		}
    
    	}()
    
    	time.Sleep(100*time.Second)
    
    }

可以看到，因为写端写入过快，再写入msg6时缓冲区已满，执行default丢弃了msg6，读端在取走msg5后, 取走的不是msg6，而是msg7

![image.png][image.png 1]

[image.png]: /images/20211220/652b0c626b24418a81419d31e5d0d406.png
[image.png 1]: /images/20211220/2e7c5eeaf36748929335a978d565a3d6.png