go channel

helww · · 2974 次点击 · · 开始浏览

这是一个创建于的文章，其中的信息可能已经有所发展或是发生改变。

channel是golang用来线程间通信而设计的，可以理解为异步IO。常用的应用场景：等待mysql的返回值，等待curl请求的返回值，等待定时器返回等。

本来想展示channel遇到的各种错误，但是有些错误不重要，如果写出来会让整篇文章先得不那么顺畅，所以只写重要的点，忽略不重要的点。

channel的写入读取

初步理解：channel可以理解为buffer，支持写入操作和读取操作。

package main

import (
    "fmt"
)

var _ = fmt.Sprintf("")

var ch chan int = make(chan int, 1)

func main() {
   //写入channel
    ch <- 1
    //读取channel
    mych := <-ch                                                                                                                      
    fmt.Println(mych)

    var stop string
    fmt.Scanln(&stop)
    fmt.Println(stop)
}

输出：

1
abc
abc

注意：channel的写入和读取最好是成对使用，如果不成对出现的话，读者可能需要自己实践和考虑下。

select机制

select可以用来判断channel是否超时

select支持多个channel的等待，如果有一个返回则继续执行，也支持default（对default没有遇到合适的例子）。

想象一种场景，主线程在等待某个channel返回，但是该channel执行时间过长，主线程判断超时需要继续执行，而不是永久等待。这种场景下就能用到select。看下面的例子

package main                                                                                                                          

import (
    "fmt"
    "runtime"
    "time"
)

var _ = fmt.Sprintf("")

var ch chan int = make(chan int, 1)

func main() {
    runtime.GOMAXPROCS(runtime.NumCPU())

    go writeCh()
    readCh()

    var stop string
    fmt.Scanln(&stop)
    fmt.Println(stop)
}

func readCh() {
    select {
    case ch1 := <-ch:
        fmt.Println(ch1)
        return
    //设置1秒超时
    case <-time.After(time.Second):
        fmt.Println("read timeout")
    }
}

func writeCh() {
    //等待2秒后写入，使超时生效
    time.Sleep(time.Second * 2)
    ch <- 1
}

/*
输出：
read timeout
abc
abc
*/

注意：这个例子中引入了select和go rountine，读取进程依据两个channel的返回次序执行，先返回先执行。可以看到timeout先返回。（可以试试把writeCh的Sleep去掉）

推荐的调用顺序是和上面例子是一致的，先go程调用写入进程，主线程中执行读取操作。两者的顺序不能反

channel的关闭

package main                                                                                                                          

import (
    "fmt"
    "runtime"
    "time"
)

var _ = fmt.Sprintf("")

var ch chan int = make(chan int, 1)

func main() {
    runtime.GOMAXPROCS(runtime.NumCPU())

    go writeCh()
    readCh()

    var stop string
    fmt.Scanln(&stop)
    fmt.Println(stop)

    close(ch)
               
    var more bool
    var chi int
    //第一个返回channel的值，第二个返回是否还有更多的数据
    chi, more = <-ch
    fmt.Println(chi, more)
                 
    //关闭后再往channel中写入会报错
    //ch <- 1    
}                
                 
func readCh() {
    select { 
    case ch1 := <-ch:
        fmt.Println(ch1)
    case <-time.After(time.Second):
        fmt.Println("read timeout")
    }
}

func writeCh() {
    //time.Sleep(time.Second * 2)
    ch <- 1
}

/*
输出：
1
abc
abc
0 false
*/