首页 > 其他 > 详细

go语音之进阶篇 channel介绍

时间:2019-01-16 17:16:27      阅读:159      评论:0      收藏:0      [点我收藏+]

1、channel介绍

和map类似,channel也一个对应make创建的底层数据结构的引用。

 当我们复制一个channel或用于函数参数传递时,我们只是拷贝了一个channel引用,因此调用者何被调用者将引用同一个channel对象。和其它的引用类型一样,channel的零值也是nil。

 定义一个channel时,也需要定义发送到channel的值的类型。channel可以使用内置的make()函数来创建:

    make(chan Type) //等价于make(chan Type, 0)
    make(chan Type, capacity)

 当 capacity= 0 时,channel 是无缓冲阻塞读写的,当capacity> 0 时,channel 有缓冲、是非阻塞的,直到写满 capacity个元素才阻塞写入。

 channel通过操作符<-来接收和发送数据,发送和接收数据语法:

    channel <- value      //发送value到channel
    <-channel             //接收并将其丢弃
    x := <-channel        //从channel中接收数据,并赋值给x
    x, ok := <-channel    //功能同上,同时检查通道是否已关闭或者是否为空

默认情况下,channel接收和发送数据都是阻塞的,除非另一端已经准备好,这样就使得goroutine同步变的更加的简单,而不需要显式的lock。

示例:

package main

import (
	"fmt"
	"time"
)

//全局变量,创建一个channel
var ch = make(chan int)

//定义一个打印机,参数为字符串,按每个字符打印
//打印机属于公共资源
func Printer(str string) {
	for _, data := range str {
		fmt.Printf("%c", data)
		time.Sleep(time.Second)
	}
	fmt.Printf("\n")
}

//person1执行完后,才能到person2执行
func person1() {
	Printer("hello")
	ch <- 666 //给管道写数据,发送
}

func person2() {
	<-ch //从管道取数据,接收,如果通道没有数据他就会阻塞
	Printer("world")
}

func main() {
	//新建2个协程,代表2个人,2个人同时使用打印机
	go person1()
	go person2()

	//特地不让主协程结束,死循环
	for {

	}
}

执行结果:

hello
world

  

 

go语音之进阶篇 channel介绍

原文:https://www.cnblogs.com/nulige/p/10277990.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!