关于go:Go-快速入门指南-遍历通道

概述

倡议先浏览 range, 非缓冲通道, 缓冲通道。

range 除了能够遍历字符串、切片、数组等数据结构外，还能够遍历通道。

语法规定

和遍历其余数据结构不同，遍历通道时没有 索引 的概念，只有值，语法如下:

for v := range ch { // v 是从通道接管到的值
// do something ...
}

应用规定

1. 遍历一个空的通道 (值为 nil) 时，阻塞
2. 遍历一个阻塞 && 未敞开的通道时，阻塞
3. 遍历一个阻塞 && 已敞开的通道时，不做任何事件
4. 遍历一个非阻塞 && 未敞开的通道时，就接管通道内的所有缓存数据，而后阻塞
5. 遍历一个非阻塞 && 已敞开的通道时，就接管通道内的所有缓存数据，而后返回

例子

遍历一个空的通道

package main

import (
    "fmt"
    "time"
)

func main() {
    var done chan bool

    go func() {
        for v := range done {fmt.Printf("v = %v\n", v)
            break
        }

        fmt.Println("range broken") // 执行不到这里
    }()

    time.Sleep(time.Second)
}

// $ go run main.go
// 没有任何输入 

遍历一个阻塞 && 未敞开的通道

package main

import (
    "fmt"
    "time"
)

func main() {done := make(chan bool)

    go func() {
        for v := range done {fmt.Printf("v = %v\n", v)
            break
        }

        fmt.Println("range broken") // 执行不到这里
    }()

    time.Sleep(time.Second)
}

// $ go run main.go
// 没有任何输入 

遍历一个阻塞 && 已敞开的通道

package main

func main() {ch := make(chan string)
    close(ch)
    for v := range ch {println(v)
    }
}

// $ go run main.go
// 没有任何输入 

遍历一个非阻塞 && 未敞开的通道

通道中无缓存数据，阻塞

package main

import (
    "fmt"
    "time"
)

func main() {ch := make(chan string, 1)

    go func() {
        for v := range ch {fmt.Printf("v = %v\n", v)
            break
        }

        fmt.Println("range broken") // 执行不到这里
    }()

    time.Sleep(time.Second)
}

// $ go run main.go
// 没有任何输入 

通道中有 1 个数据

package main

func main() {ch := make(chan string, 1)
    ch <- "hello world"

    for v := range ch {println(v)
    }

    // 代码执行不到这里
    close(ch)
}

// $ go run main.go
// 输入如下
/**
  v = hello world
*/

通道中有多个数据

package main

import (
    "fmt"
    "time"
)

func main() {ch := make(chan string, 3)
    for i := 0; i < 3; i++ {ch <- "hello world"}

    go func() {
        for v := range ch {fmt.Printf("v = %v\n", v)
        }

        fmt.Println("range broken") // 执行不到这里
    }()

    time.Sleep(time.Second)
}

// $ go run main.go
// 输入如下
/**
  v = hello world
  v = hello world
  v = hello world
*/

遍历一个非阻塞 && 已敞开的通道时

通道中无缓存数据，间接返回

package main

func main() {ch := make(chan string, 1)
    close(ch)

    for v := range ch {println(v)
    }
}

// $ go run main.go
// 没有输入 

通道中有 1 个数据

package main

func main() {ch := make(chan string, 1)
    ch <- "hello world"
    close(ch)

    for v := range ch {println(v)
    }
}

// $ go run main.go
// 输入如下
/**
  hello world
*/

通道中有多个数据

package main

func main() {ch := make(chan string, 3)
    for i := 0; i < 3; i++ {ch <- "hello world"}
    close(ch)

    for v := range ch {println(v)
    }
}

// $ go run main.go
// 输入如下
/**
  hello world
  hello world
  hello world
*/

分割我