From 2a0f7fdd3cad05575f4e49dd3838e199ea23e607 Mon Sep 17 00:00:00 2001 From: astaxie Date: Mon, 3 Sep 2012 14:16:47 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B9=B6=E5=8F=91=E5=AE=8C=E6=88=90=E6=89=80?= =?UTF-8?q?=E6=9C=89=E5=86=99=E4=BD=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- 2.6.md | 4 ++-- 2.7.md | 74 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 76 insertions(+), 2 deletions(-) diff --git a/2.6.md b/2.6.md index 98efd6ca..4ef091b7 100644 --- a/2.6.md +++ b/2.6.md @@ -356,11 +356,11 @@ Go里面真正吸引人的是他内置的逻辑语法,就像我们在学习Str ###反射 Go语言实现了反射,所谓反射就是动态运行时的状态。我们一般用到的包是reflect包。如何运用reflect包,官方的这篇文章详细的讲解了reflect包的实现原理,[laws of reflection](http://golang.org/doc/articles/laws_of_reflection.html) -下面我简要的讲解一下一般的使用,我们使用reflect大概的分成三步,首先我们要去反射是一个类型的值,需要把它转化成interface(reflect.Type或者reflect.Value,根据不同的情况调用不同的函数)。这两种获取方式如下: +下面我简要的讲解一下一般的使用,我们使用reflect大概的分成三步,首先我们要去反射是一个类型的值(这些值都实现了空interface),需要把它转化成reflect对象(reflect.Type或者reflect.Value,根据不同的情况调用不同的函数)。这两种获取方式如下: t := reflect.TypeOf(i) //得到类型的元数据,通过t我们能获取类型定义里面的所有元素 v := reflect.ValueOf(i) //得到实际的值,通过v我们获取存储在里面的值,还可以去改变值 -获取这个对象之后我们就可以进行一些操作了,例如 +获取这个对象之后我们就可以进行一些操作了,也就是reflect对象转化成相应的值,例如 tag := t.Elem().Field(0).Tag //获取定义在strcut里面的标签 name := v.Elem().Field(0).String() //获取存储在第一个字段里面的值 获取反射值能返回相应的类型和数值 diff --git a/2.7.md b/2.7.md index 847ebbc5..c96d67d5 100644 --- a/2.7.md +++ b/2.7.md @@ -96,8 +96,82 @@ channel通过操作符`<-`来接收和发送数据 } ##Range和Close +上面这个例子中,我们需要读取两次c,这样不是很方便,Go考虑到了这一点,所以也可以通过range,像操作slice或者map一样操作缓存类型的channel,请看下面的例子 + + package main + + import ( + "fmt" + ) + + func fibonacci(n int, c chan int) { + x, y := 1, 1 + for i := 0; i < n; i++ { + c <- x + x, y = y, x + y + } + close(c) + } + + func main() { + c := make(chan int, 10) + go fibonacci(cap(c), c) + for i := range c { + fmt.Println(i) + } + } + +`for i := range c`能够不断的读取channel里面的数据,直到该channel被显示的关闭。上面代码我们看到可以显示的关闭channel,生产者通过关键字`close`函数关闭channel。关闭channel之后就无法再发送任何数据了,在消费方可以通过语法`v, ok := <-ch`测试channel是否被关闭。如果ok返回false,那么说明channel已经没有任何数据并且已经被关闭。 + +>记住应该在生产者的地方关闭channel,而不是消费的地方去关闭它,这样容易引起panic + +>另外记住一点的就是channel不像文件之类的,不需要经常去关闭,只有当你确实没有任何发送数据了,或者你想显示的结束range循环之类的 ##Select +我们上面介绍的都是只有一个channel的情况,那么如果存在多个channel的时候,我们该如何操作呢,Go里面提供了一个关键字`select`,通过`select`可以监听channel上输入的数据。 + +`select`默认都是阻塞的,只有当channel数据到达之后才会运行,当多个channel都准备好的时候,select是随机的读取一个执行的。 + + package main + + import "fmt" + + func fibonacci(c, quit chan int) { + x, y := 1, 1 + for { + select { + case c <- x: + x, y = y, x + y + case <-quit: + fmt.Println("quit") + return + } + } + } + + func main() { + c := make(chan int) + quit := make(chan int) + go func() { + for i := 0; i < 10; i++ { + fmt.Println(<-c) + } + quit <- 0 + }() + fibonacci(c, quit) + } + +虽然goroutine是并发执行的,但是它们并不是并行运行的。如果不告诉Go额外的东西,同一时刻只会有一个goroutine执行。利用runtime.GOMAXPROCS(n)可以设置goroutine并行执行的数量。GOMAXPROCS 设置了同时运行的CPU 的最大数量,并返回之前的设置。如果n < 1,不会改变当前设置。以后Go的新版本中调度得到改进后,这将被移除。 + +在`select`里面还有default语法,`select`其实就是类似switch的功能,default就是当其他channel都没有准备好的时候,默认执行的。 + + select { + case i := <-c: + // use i + default: + // 当c阻塞的时候执行这里 + } + ## links * [目录]()