zoukankan      html  css  js  c++  java
  • go语言之进阶篇有缓冲channel

    1、有缓冲channel

    示例:  有缓存会阻塞,当读取完其中数值时,又可以写入。

    package main
    
    import (
    	"fmt"
    	"time"
    )
    
    func main() {
    	//创建一个有缓存的channel
    	ch := make(chan int, 3)
    
    	//len(ch)缓冲区剩余数据个数, cap(ch)缓冲区大小
    	fmt.Printf("len(ch) = %d, cap(ch)= %d
    ", len(ch), cap(ch))
    
    	//新建协程
    	go func() {
    		for i := 0; i < 10; i++ {
    			ch <- i //往chan写内容
    			fmt.Printf("子协程[%d]: len(ch) = %d, cap(ch)= %d
    ", i, len(ch), cap(ch))
    		}
    	}()
    
    	//延时
    	time.Sleep(2 * time.Second)
    
    	for i := 0; i < 10; i++ {
    		num := <-ch //读管道中内容,没有内容前,阻塞
    		fmt.Println("num = ", num)
    	}
    
    }
    

    执行结果:

    len(ch) = 0, cap(ch)= 3
    子协程[0]: len(ch) = 1, cap(ch)= 3
    子协程[1]: len(ch) = 2, cap(ch)= 3
    子协程[2]: len(ch) = 3, cap(ch)= 3
    num =  0
    num =  1
    num =  2
    num =  3
    子协程[3]: len(ch) = 3, cap(ch)= 3
    子协程[4]: len(ch) = 0, cap(ch)= 3
    num =  4
    num =  5
    子协程[5]: len(ch) = 1, cap(ch)= 3
    子协程[6]: len(ch) = 0, cap(ch)= 3
    子协程[7]: len(ch) = 1, cap(ch)= 3
    子协程[8]: len(ch) = 2, cap(ch)= 3
    子协程[9]: len(ch) = 3, cap(ch)= 3
    num =  6
    num =  7
    num =  8
    num =  9
    

      

  • 相关阅读:
    emacs配置emacs-clang-complete-async
    emacs之配置自动安装脚本
    vim之YCM配置
    vim之vundle
    emacs之配置php
    kettle的日志
    kettle的报错解决机制
    kettle优化
    将BAT文件注册为服务的方法
    使用powerdesinger逆向生成表结构
  • 原文地址:https://www.cnblogs.com/nulige/p/10286793.html
Copyright © 2011-2022 走看看