golang中channel什么时候会阻塞

2024-08-21 13:28
文章标签 golang channel 阻塞

本文主要是介绍golang中channel什么时候会阻塞,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在 Go 中,通道(channel)会在以下情况下阻塞:

1. 发送操作阻塞

  • 无缓冲通道: 当你向无缓冲通道发送数据时,如果没有其他 goroutine 读取数据,发送操作将阻塞。

    ch := make(chan int) // 无缓冲通道
    ch <- 1 // 阻塞,直到有接收者
    
  • 缓冲通道已满: 当缓冲通道的缓冲区已满时,尝试发送数据将阻塞,直到有空间可用。

    ch := make(chan int, 2) // 缓冲通道,大小为 2
    ch <- 1
    ch <- 2
    // ch <- 3 // 阻塞,直到有人接收
    

2. 接收操作阻塞

  • 无缓冲通道: 当你从无缓冲通道接收数据时,如果没有其他 goroutine 发送数据,接收操作将阻塞。

    ch := make(chan int) // 无缓冲通道
    val := <-ch // 阻塞,直到有人发送
    
  • 缓冲通道为空: 当尝试从缓冲通道接收数据时,如果通道为空,接收操作将阻塞,直到有数据可用。

    ch := make(chan int, 2) // 缓冲通道
    // ch <- 1
    // val := <-ch // 阻塞,直到有人发送数据
    

3. select 语句阻塞

  • select 会阻塞,直到其中一个 case 可执行。如果所有的 case 都不可执行(例如,所有的通道都没有数据可读或没有空间可写),则 select 将阻塞。

    select {
    case msg := <-ch1: // 如果 ch1 没有数据则阻塞fmt.Println(msg)
    case ch2 <- 2: // 如果 ch2 满则阻塞fmt.Println("Sent to ch2")
    }
    

4. 避免阻塞

  • 使用 default: 在 select 中添加 default 分支可以避免阻塞。

    select {
    case msg := <-ch:fmt.Println(msg)
    default:fmt.Println("No messages received")
    }
    

总结

通道的阻塞机制是 Go 实现并发的重要特性,它确保了数据的安全传递和同步。在使用通道时,理解何时会阻塞对于编写高效的并发程序至关重要。

这篇关于golang中channel什么时候会阻塞的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1093289

相关文章

解读Redis秒杀优化方案(阻塞队列+基于Stream流的消息队列)

《解读Redis秒杀优化方案(阻塞队列+基于Stream流的消息队列)》该文章介绍了使用Redis的阻塞队列和Stream流的消息队列来优化秒杀系统的方案,通过将秒杀流程拆分为两条流水线,使用Redi... 目录Redis秒杀优化方案(阻塞队列+Stream流的消息队列)什么是消息队列?消费者组的工作方式每

Golang操作DuckDB实战案例分享

《Golang操作DuckDB实战案例分享》DuckDB是一个嵌入式SQL数据库引擎,它与众所周知的SQLite非常相似,但它是为olap风格的工作负载设计的,DuckDB支持各种数据类型和SQL特性... 目录DuckDB的主要优点环境准备初始化表和数据查询单行或多行错误处理和事务完整代码最后总结Duck

Golang的CSP模型简介(最新推荐)

《Golang的CSP模型简介(最新推荐)》Golang采用了CSP(CommunicatingSequentialProcesses,通信顺序进程)并发模型,通过goroutine和channe... 目录前言一、介绍1. 什么是 CSP 模型2. Goroutine3. Channel4. Channe

Golang使用minio替代文件系统的实战教程

《Golang使用minio替代文件系统的实战教程》本文讨论项目开发中直接文件系统的限制或不足,接着介绍Minio对象存储的优势,同时给出Golang的实际示例代码,包括初始化客户端、读取minio对... 目录文件系统 vs Minio文件系统不足:对象存储:miniogolang连接Minio配置Min

Golang使用etcd构建分布式锁的示例分享

《Golang使用etcd构建分布式锁的示例分享》在本教程中,我们将学习如何使用Go和etcd构建分布式锁系统,分布式锁系统对于管理对分布式系统中共享资源的并发访问至关重要,它有助于维护一致性,防止竞... 目录引言环境准备新建Go项目实现加锁和解锁功能测试分布式锁重构实现失败重试总结引言我们将使用Go作

springboot体会BIO(阻塞式IO)

使用springboot体会阻塞式IO 大致的思路为: 创建一个socket服务端,监听socket通道,并打印出socket通道中的内容。 创建两个socket客户端,向socket服务端写入消息。 1.创建服务端 public class RedisServer {public static void main(String[] args) throws IOException {

多路转接之select(fd_set介绍,参数详细介绍),实现非阻塞式网络通信

目录 多路转接之select 引入 介绍 fd_set 函数原型 nfds readfds / writefds / exceptfds readfds  总结  fd_set操作接口  timeout timevalue 结构体 传入值 返回值 代码 注意点 -- 调用函数 select的参数填充  获取新连接 注意点 -- 通信时的调用函数 添加新fd到

Go Channel的实现

channel作为goroutine间通信和同步的重要途径,是Go runtime层实现CSP并发模型重要的成员。在不理解底层实现时,经常在使用中对channe相关语法的表现感到疑惑,尤其是select case的行为。因此在了解channel的应用前先看一眼channel的实现。 Channel内存布局 channel是go的内置类型,它可以被存储到变量中,可以作为函数的参数或返回值,它在r

Golang进程权限调度包runtime

关于 runtime 包几个方法: Gosched:让当前线程让出 cpu 以让其它线程运行,它不会挂起当前线程,因此当前线程未来会继续执行GOMAXPROCS:设置最大的可同时使用的 CPU 核数Goexit:退出当前 goroutine(但是defer语句会照常执行)NumGoroutine:返回正在执行和排队的任务总数GOOS:目标操作系统NumCPU:返回当前系统的 CPU 核数量 p

Golang 网络爬虫框架gocolly/colly(五)

gcocolly+goquery可以非常好地抓取HTML页面中的数据,但碰到页面是由Javascript动态生成时,用goquery就显得捉襟见肘了。解决方法有很多种: 一,最笨拙但有效的方法是字符串处理,go语言string底层对应字节数组,复制任何长度的字符串的开销都很低廉,搜索性能比较高; 二,利用正则表达式,要提取的数据往往有明显的特征,所以正则表达式写起来比较简单,不必非常严谨; 三,使