go 管道关闭和循环使用

2022-01-29 10:34:53 阅读：128 来源： 互联网

package main

import (
	"fmt"
	"sync"
	"time"
)

/*
channel提供了一种通信机制 定向 消息队列

*/
var wgt sync.WaitGroup
//消费者
func cousumer(queue chan string){
	defer wgt.Done()
	//第一种遍历管道
	//for {
	//	data :=<- queue
	//	fmt.Println(data)
	//	time.Sleep(time.Second)
	//}
	//第二种管道关闭处理
	for{
		data,ok:=<-queue
		if !ok {
			break
		}
		fmt.Println(data)
		time.Sleep(time.Second)
	}
	//遍历管道
	//for data :=range queue{
	//	fmt.Println(data)
	//	time.Sleep(time.Second*1)
	//}
	//data :=<-queue
	//fmt.Println(data)
}

func main(){
	//静态语言 需要申明类型
	//定义一个channel  发一个，就需要消费一个
	var msg chan string
	//初始化这个channel 初始化有两种方式: 1.无缓冲空间的管道 2.有缓存空间的管道
	//msg=make(chan int)//没有缓冲空间的管道 fatal error: all goroutines are asleep - deadlock!
	msg=make(chan string,1)//有缓存空间的 如果缓冲空间满了也会报  fatal error: all goroutines are asleep - deadlock!
	// go 语言中使用make初始化有三种 1.slice 2.map 3.channel
	msg <- "s"//把字符串s放入 channel中
	//msg<-"ww" //管道看起来好像是有空间的数组
    // data :=<- msg  //将箭头右边的值放到左边 //通道数据读取完之后，就不能在读取了
    //加协程 waitGroup的目的是为了控制流程，使主进程和子进程在子进程全部完成之后，结束主进程
    wgt.Add(1)
    go cousumer(msg)  //
	msg <- "测试"
	close(msg) //关闭管道
    // 关闭channel 1.已经关闭的channel不能再发送数据了 2.关闭的channel能取数据吗？
    // 已经关闭的channel 能够继续读数据 直到数据取完为止
	wgt.Wait()
    //fmt.Println(data)
}

标签：defer,chan,sync,wgt,管道,关闭,go
来源： https://www.cnblogs.com/kevin-yang123/p/15854456.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

go 管道关闭和循环使用