脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 脚本专栏 → Golang → golang channel读取

golang channel读取数据的几种情况

 更新时间：2023年02月01日 09:53:06   作者：-_-void  
本文主要介绍了golang channel读取数据的几种情况，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

用var定义channel且不make

wg := sync.WaitGroup{}
var ch chan string

read := func() {
    fmt.Println("reading")
    s := <-ch
    fmt.Println("read:", s)
    wg.Done()
}

write := func() {
    fmt.Println("writing")
    s := "t"
    ch <- s
    fmt.Println("write:", s)
    wg.Done()
}

wg.Add(2)
go read()
go write()

fmt.Println("waiting")
wg.Wait()

输出：

waiting
writing
reading
fatal error: all goroutines are asleep - deadlock!

这种情况并不是报错空指针，而是死锁。加上make看看

用var定义channel且make

wg := sync.WaitGroup{}
var ch = make(chan string)

read := func() {
    fmt.Println("reading")
    s := <-ch
    fmt.Println("read:", s)
    wg.Done()
}

write := func() {
    fmt.Println("writing")
    s := "t"
    ch <- s
    fmt.Println("write:", s)
    wg.Done()
}

wg.Add(2)
go read()
go write()

输出

waiting
writing
reading
read: t
write: t

这种情况没什么毛病，之所以先输出的read，是因为IO机制。下面给写加上for

直给写操作加for

wg := sync.WaitGroup{}
var ch = make(chan string)

read := func() {
    fmt.Println("reading")
    s := <-ch
    fmt.Println("read:", s)
    wg.Done()
}

write := func() {
    for {
        fmt.Println("writing")
        s := "t"
        ch <- s
        fmt.Println("write:", s)
    }
    wg.Done()
}

wg.Add(2)
go read()
go write()

fmt.Println("waiting")
wg.Wait()
fmt.Println("finish")

输出

waiting
reading
writing
write: t
writing
read: t
fatal error: all goroutines are asleep - deadlock!

报错说所有的协程都睡着，意思就是runtime发现没有能拿来调度的协程了，报错退出。如果是在大项目中，这里则会阻塞，runtime会调度其他可运行的协程。下面把for移到读操作上。

直给读操作加for

wg := sync.WaitGroup{}
var ch = make(chan string)

read := func() {
    for {
        fmt.Println("reading")
        s := <-ch
        fmt.Println("read:", s)
    }
    wg.Done()
}

write := func() {
    fmt.Println("writing")
    s := "t"
    ch <- s
    fmt.Println("write:", s)
    wg.Done()
}

wg.Add(2)
go read()
go write()

fmt.Println("waiting")
wg.Wait()
fmt.Println("finish")

输出

waiting
reading
writing
write: t
read: t
reading
fatal error: all goroutines are asleep - deadlock!

跟上面现象基本一样，不再赘述，然后给俩操作都加上for

读写都加for

wg := sync.WaitGroup{}
var ch = make(chan string)

read := func() {
    for {
        fmt.Println("reading")
        s := <-ch
        fmt.Println("read:", s)
    }
    wg.Done()
}

write := func() {
    for {
        fmt.Println("writing")
        s := "t"
        ch <- s
        fmt.Println("write:", s)
    }
    wg.Done()
}

wg.Add(2)
go read()
go write()

fmt.Println("waiting")
wg.Wait()
fmt.Println("finish")

输出

waiting
writing
reading
read: t
write: t
writing
reading
read: t
reading
write: t
writing
write: t
writing
...

结果当然就是死循环了，这个很好理解。接下来才是本文的重点：读数据的第二个参数。我们先保持其他的都不动，在读的时候接收第二个返回值。

读channel的第二个返回值

wg := sync.WaitGroup{}
var ch = make(chan string)

read := func() {
    for {
        fmt.Println("reading")
        s, ok := <-ch
        fmt.Println("read:", s, ok)
    }
    wg.Done()
}

write := func() {
    for {
        fmt.Println("writing")
        s := "t"
        ch <- s
        fmt.Println("write:", s)
    }
    wg.Done()
}

wg.Add(2)
go read()
go write()

fmt.Println("waiting")
wg.Wait()
fmt.Println("finish")

输出

waiting
writing
reading
read: t true
reading
write: t
writing
write: t
writing
read: t true
reading
read: t true
reading
write: t
...

可以看出来，这第二个返回值是个bool类型，目前全都是true。那么什么时候会是false呢，把channel关上试试。为了更直观，把字符串的长度一起输出

关闭channel继续读

wg := sync.WaitGroup{}
var ch = make(chan string)

read := func() {
    for {
        fmt.Println("reading")
        s, ok := <-ch
        fmt.Println("read:", len(s), s, ok)
    }
    wg.Done()
}

write := func() {
    for i := 0; i < 5; i++ {
        fmt.Println("writing")
        s := "t"
        ch <- s
        fmt.Println("write:", s)
    }
    wg.Done()
    close(ch)
}

wg.Add(2)
go read()
go write()

fmt.Println("waiting")
wg.Wait()
fmt.Println("finish")

输出

waiting
writing
reading
read: 1 t true
reading
write: t
writing
write: t
writing
read: 1 t true
reading
read: 1 t true
reading
write: t
writing
write: t
writing
read: 1 t true
reading
read: 1 t true
reading
write: t
read: 0  false
reading
read: 0  false
reading
read: 0  false
...

接下来就是很规律的死循环了。这样是不是可以猜测，从已经close的channle读数据，会读到该数据类型的零值，且第二个返回值为false？再试试给channel加个buffer，先写完关上再开始读

写完然后关闭channel再开始读

wg := sync.WaitGroup{}
var ch = make(chan string, 5)

read := func() {
    for {
        fmt.Println("reading")
        s, ok := <-ch
        fmt.Println("read:", len(s), s, ok)
    }
    wg.Done()
}

write := func() {
    for i := 0; i < 5; i++ {
        fmt.Println("writing")
        s := "t"
        ch <- s
        fmt.Println("write:", s)
    }
    wg.Done()
    close(ch)
    fmt.Println("closed")
}

wg.Add(2)
write()
go read()

fmt.Println("waiting")
wg.Wait()
fmt.Println("finish")

输出

writing
write: t
writing
write: t
writing
write: t
writing
write: t
writing
write: t
closed
waiting
reading
read: 1 t true
reading
read: 1 t true
reading
read: 1 t true
reading
read: 1 t true
reading
read: 1 t true
reading
read: 0  false
reading
read: 0  false
reading
read: 0  false
...

我们把写操作前的go关键字去了，并且在关闭channel之后加了log。可以很清晰的看到，先往channel里写了5次，然后close了，之后才有wait及read的log。并且前5个ok是true，后面循环输出false。现在我们可以得出结论当channel关闭且数据都读完了，再读数据会读到该数据类型的零值，且第二个返回值为false。下面再套上select

加个select

wg := sync.WaitGroup{}
var ch = make(chan string, 5)

read := func() {
    for {
        fmt.Println("reading")
        select {
        case s, ok := <-ch:
            fmt.Println("read:", len(s), s, ok)
        }

    }
    wg.Done()
}

write := func() {
    for i := 0; i < 5; i++ {
        fmt.Println("writing")
        s := "t"
        ch <- s
        fmt.Println("write:", s)
    }
    wg.Done()
    close(ch)
    fmt.Println("closed")
}

wg.Add(2)
write()
go read()

fmt.Println("waiting")
wg.Wait()
fmt.Println("finish")

输出

writing
write: t
writing
write: t
writing
write: t
writing
write: t
writing
write: t
closed
waiting
reading
read: 1 t true
reading
read: 1 t true
reading
read: 1 t true
reading
read: 1 t true
reading
read: 1 t true
reading
read: 0  false
reading
read: 0  false
reading
read: 0  false
...

很明显跟上面现象一致，如果忘了关闭channel呢？

channel未及时关闭

wg := sync.WaitGroup{}
var ch = make(chan string, 5)

read := func() {
    for {
        fmt.Println("reading")
        select {
        case s, ok := <-ch:
            fmt.Println("read:", len(s), s, ok)
        }

    }
    wg.Done()
}

write := func() {
    for i := 0; i < 5; i++ {
        fmt.Println("writing")
        s := "t"
        ch <- s
        fmt.Println("write:", s)
    }
    wg.Done()
    //close(ch)
    //fmt.Println("closed")
}

wg.Add(2)
write()
go read()

fmt.Println("waiting")
wg.Wait()
fmt.Println("finish")

输出

writing
write: t
writing
write: t
writing
write: t
writing
write: t
writing
write: t
waiting
reading
read: 1 t true
reading
read: 1 t true
reading
read: 1 t true
reading
read: 1 t true
reading
read: 1 t true
reading
fatal error: all goroutines are asleep - deadlock!

睡着了，然后报错。跟上面情况一样，如果是在大项目中，runtime会调度其他可运行的协程。最后来总结一下怎么操作才算优(sao)雅(qi)。

总结

  • 对写的一方来说，一定记着及时关闭channel，避免出现协程泄露。虽然它占得资源少，省点电不香么。
  • 对读的一方来说，除非十分确定数据的个数，最好是用for来读数据，省的在“管儿”里有“野数据”造成内存泄露。同时根据第二个返回值的真假来控制for循环，避免出现“无效工作量”

到此这篇关于golang channel读取数据的几种情况的文章就介绍到这了,更多相关golang channel读取内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • Golang中的错误处理深入分析

    Golang中的错误处理深入分析

    Go错误处理类似C语言，没有提供任何异常，以及类java语言使用的try/catch异常处理机制。Go异常处理仅简化为预定义的Error类型，Go没有提供异常处理机制，不能抛出类似许多其他语言的异常。相反，Golang集成了新的错误处理机制，如panic和recovery
    2023-01-01
  • Golang控制协程执行顺序方法详解

    Golang控制协程执行顺序方法详解

    这篇文章主要介绍了Golang控制协程执行顺序的方法，Golang的语法和运行时直接内置了对并发的支持。Golang里的并发指的是能让某个函数独立于其他函数运行的能力
    2022-11-11
  • 解决golang读取http的body时遇到的坑

    解决golang读取http的body时遇到的坑

    这篇文章主要介绍了解决golang读取http的body时遇到的坑，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2020-12-12
  • golang NewRequest/gorequest实现http请求的示例代码

    golang NewRequest/gorequest实现http请求的示例代码

    本文主要介绍了golang NewRequest/gorequest实现http请求的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2022-08-08
  • Go语言error的设计理念及背景演化详解

    Go语言error的设计理念及背景演化详解

    这篇文章主要为大家介绍了Go语言error的设计理念及背景演化详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2022-12-12
  • 简单讲解Go程序中使用MySQL的方法

    简单讲解Go程序中使用MySQL的方法

    这篇文章主要介绍了Go程序中使用MySQL的方法,需要使用第三方包来进行连接,需要的朋友可以参考下
    2015-10-10
  • GO中的条件变量sync.Cond详解

    GO中的条件变量sync.Cond详解

    条件变量是基于互斥锁的，它必须基于互斥锁才能发挥作用，条件变量的初始化离不开互斥锁，并且它的方法有点也是基于互斥锁的，这篇文章主要介绍了GO的条件变量sync.Cond,需要的朋友可以参考下
    2023-01-01
  • golang线程安全的map实现

    golang线程安全的map实现

    这篇文章主要介绍了golang线程安全的map实现，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2019-03-03
  • go zero微服务实战处理每秒上万次的下单请求

    go zero微服务实战处理每秒上万次的下单请求

    这篇文章主要为大家介绍了go zero微服务实战处理每秒上万次的下单请求示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2022-07-07
  • Go语言开发k8s之ConfigMap操作解析

    Go语言开发k8s之ConfigMap操作解析

    这篇文章主要为大家介绍了Go语言开发k8s之ConfigMap操作示例解析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2023-06-06

最新评论