Golang协程之了解管道的缓存能力

简介: 我们之前讲过,当使用make建立管道时,第二个参数为零,就证明这个管道是无缓存能力的管道。只要没人写就永远读不出来,只要没人读就永远写不进去。

Golang协程之了解管道的缓存能力

我们之前讲过,当使用make建立管道时,第二个参数为零,就证明这个管道是无缓存能力的管道。只要没人写就永远读不出来,只要没人读就永远写不进去。例如:

ch := make(chan int,0)

管道的缓冲区能被初始化为指定的缓冲区容量。 如果为零,或者省略了大小,则该通道是无缓冲的。

如果将第二个参数改为8(这里可以为任意大小),这就说明缓存能力为8,即使不读,也能写入8个元素。

package main

import (
    "fmt"
    "time"
)

func main() {
    //The channel's buffer is initialized with the specified buffer capacity.
    //If zero, or the size is omitted, the channel is unbuffered.
    ch := make(chan int,0)

    go func() {
        ch <- 123
        fmt.Println("数据已写入")
    }()

    go func() {
        time.Sleep(2*time.Second)
        x:= <- ch
        fmt.Println("数据已读出",x)
    }()

    time.Sleep(5*time.Second)
    fmt.Println("Game Over!")
}

这段代码在运行过程中,由于一条协程在写入管道缓冲区,另一条协程在读取管道的缓冲区,但是读取管道缓冲区的那条协程会sleep 两秒,所以在前两秒另一条写入管道缓冲区的协程也不能写入。

如果让写入管道缓冲区的那条协程sleep两秒,那么前两秒另一条读取管道缓冲区的协程也不能读取数据。

如果一个缓冲区大小为3的管道,写入4个值,那么第4个值就写入不了,运行结果是这样的:

写入1
写入2
写入3

下面我们来看一看管道内的元素个数及它的缓存能力吧:

package main

import (
    "fmt"
    "time"
)

func main101() {
    ch := make(chan int,3)

    go func() {
        ch <- 1
        fmt.Println("写入1")
        ch <- 2
        fmt.Println("写入2")
        ch <- 3
        fmt.Println("写入3")
        //管道的缓冲区已经存满,不能再写入!
        ch <- 4
        fmt.Println("写入4")
    }()
    time.Sleep(5 * time.Second)
}

func main() {
    ch := make(chan int,3)
    fmt.Println("元素的个数为",len(ch),"缓存能力为",cap(ch));

    ch <- 123
    fmt.Println("元素的个数为",len(ch),"缓存能力为",cap(ch));
    ch <- 123
    fmt.Println("元素的个数为",len(ch),"缓存能力为",cap(ch));
    ch <- 123
    fmt.Println("元素的个数为",len(ch),"缓存能力为",cap(ch));
    
}

运行结果是

元素的个数为 0 缓存能力为 3
元素的个数为 1 缓存能力为 3
元素的个数为 2 缓存能力为 3
元素的个数为 3 缓存能力为 3
fatal error: all goroutines are asleep - deadlock!

goroutine 1 [chan send]:
main.main()
    E:/main.go:36 +0x4e5

Process finished with exit code 2

我们可以看到管道的缓存能力是没有变化的,但是存入的元素个数是在变化的。

我们可以看到这里出现了死锁,这里主协程永远无法继续执行。

我们再来了解一下管道的有关知识。

据了解,管道是建立在堆上面的。使用make函数返回的是指针,这就是为什么我们能够在函数之间传递管道,不需要传递指向管道的指针。

ch := make(chan int,0)

使用make创建一个管道只能传输同一类型的数据,建立一个管道时需要指定一个数据类型,不允许通过一个管道传输多种类型的数据。

目录
相关文章
|
5月前
|
Go 调度 开发者
CSP模型与Goroutine调度的协同作用:构建高效并发的Go语言世界
【2月更文挑战第17天】在Go语言的并发编程中,CSP模型与Goroutine调度机制相互协同,共同构建了高效并发的运行环境。CSP模型通过通道(channel)实现了进程间的通信与同步,而Goroutine调度机制则确保了并发任务的合理调度与执行。本文将深入探讨CSP模型与Goroutine调度的协同作用,分析它们如何共同促进Go语言并发性能的提升。
|
2月前
|
NoSQL Unix 编译器
Golang协程goroutine的调度与状态变迁分析
文章深入分析了Golang中goroutine的调度和状态变迁,包括Grunnable、Gwaiting、Grunning和Gsyscall等状态,以及它们之间的转换条件和原理,帮助理解Go调度器的内部机制。
40 0
|
5月前
|
存储 Go 数据处理
Golang简单实现IO操作
Golang简单实现IO操作
49 1
|
5月前
|
设计模式 Go 调度
Golang深入浅出之-Go语言中的并发模式:Pipeline、Worker Pool等
【5月更文挑战第1天】Go语言并发模拟能力强大,Pipeline和Worker Pool是常用设计模式。Pipeline通过多阶段处理实现高效并行,常见问题包括数据竞争和死锁,可借助通道和`select`避免。Worker Pool控制并发数,防止资源消耗,需注意任务分配不均和goroutine泄露,使用缓冲通道和`sync.WaitGroup`解决。理解和实践这些模式是提升Go并发性能的关键。
70 2
|
5月前
|
负载均衡 Go 调度
使用Go语言构建高性能的Web服务器:协程与Channel的深度解析
在追求高性能Web服务的今天,Go语言以其强大的并发性能和简洁的语法赢得了开发者的青睐。本文将深入探讨Go语言在构建高性能Web服务器方面的应用,特别是协程(goroutine)和通道(channel)这两个核心概念。我们将通过示例代码,展示如何利用协程处理并发请求,并通过通道实现协程间的通信和同步,从而构建出高效、稳定的Web服务器。
|
Go
Golang 语言怎么控制并发 goroutine?
Golang 语言怎么控制并发 goroutine?
40 0
|
Go 调度 数据安全/隐私保护
Golang 并发&同步的详细原理和使用技巧
Golang 并发&同步的详细原理和使用技巧
|
安全 Go 调度
Go协程探秘:轻量、并发与性能的完美结合
Go协程探秘:轻量、并发与性能的完美结合
288 0
|
Go
Go的管道堵塞解决方案
如果没有避免管道堵塞,我们应该怎么办?
135 0
|
安全 Go
golang中的互斥锁和管道
golang中的互斥锁和管道