golang非阻塞读写channel

秒速五厘米 2022-08-31 06:48 174阅读 0赞

服务器最近压测的时候发现了问题。发现是往channel写数据，但是channel满了，导致服务器部分功能阻塞。golang的channel读或写是会造成阻塞的，但是可以用select的多路复用解决这个问题。

不阻塞读channel（也可以加上超时）

func readChan(c chan int) (int, error) { 
    	select { 
    	case num := <-c:
    		return num, nil
    	default:
    		return 0, errors.New("chan do not have data")
    	}
    }
    
    // 加上超时时间
    func readChanWithTimeout(c chan int) (int, error) { 
    	timeout := time.NewTimer(time.Microsecond * 100)
    
    	select { 
    	case num := <-c:
    		return num , nil
    	case <-timeout.C:
    		return 0, errors.New("read chan time out")
    	}
    }

非阻塞写入channel（也可以加上超时）

func writeChan(num int, c chan int) error { 
    	select { 
    	case ch <- num:
    		return nil
    	default:
    		return errors.New("chan is full")
    	}
    }
    
    // 加上超时时间
    func writeChanWithTimeout(num int, c chan int) error { 
    	timeout := time.NewTimer(time.Microsecond * 100)
    
    	select { 
    	case c <- num:
    		return nil
    	case <-timeout.C:
    		return errors.New("write chan time out")
    	}
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，174人围观）

还没有评论，来说两句吧...

相关阅读

相关 Golang向已关闭的channel中读和向channel中写有何区别？

向已关闭的channel中读和向channel中写有明显的区别。当通道被关闭后，对其发送操作会引发panic，因为通道已经关闭，任何进一步的写入都将失败。对于读取操作，

╰半橙微兮°/ 2024年02月19日 10:27/ 0 赞/ 36 阅读

相关 golang管道channel的基本使用：读、写数据到管道

![请添加图片描述][20210131155502447.png] ![请添加图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow

太过爱你忘了你带给我的痛/ 2023年10月05日 18:51/ 0 赞/ 23 阅读

相关算法：golang使用channel实现非阻塞队列和超时阻塞队列

Channel是Golang中非常重要的数据结构, 默认它是阻塞的。那么如何实现一个非阻塞队列呢？ package main import (

忘是亡心i/ 2023年02月26日 10:29/ 0 赞/ 15 阅读

相关【NIO】Channel：管道与流，及非阻塞的Channel

在[上一篇][Link 1]我们讲了 Buffer，它在整个 NIO 体系中就像一速度很快的汽车，负责装载数据的，但是光有车没有路可不行啊！而 Channel 就好比高速路，连

迷南。/ 2022年12月30日 03:40/ 0 赞/ 134 阅读

相关 golang 文件读写

话不多说，上代码 package main import ( "bufio" "fmt" "io" "

朴灿烈づ我的快乐病毒、/ 2022年12月05日 05:21/ 0 赞/ 184 阅读

相关 Golang 关闭的Channel读写问题

1.向一个已关闭的channel发送元素会引起panic panic: send on closed channel package main i

r囧r小猫/ 2022年11月29日 00:57/ 0 赞/ 247 阅读

相关一招教你无阻塞读写Golang channel

无论是无缓冲通道，还是有缓冲通道，都存在阻塞的情况，教你一招再也不遇到channel阻塞的问题。这篇文章会介绍，哪些情况会存在阻塞，以及如何使用select解决阻塞。

深藏阁楼爱情的钟/ 2022年09月13日 15:21/ 0 赞/ 196 阅读

相关 golang非阻塞读写channel

服务器最近压测的时候发现了问题。发现是往channel写数据，但是channel满了，导致服务器部分功能阻塞。golang的channel读或写是会造成阻塞的，但是可以用sel

秒速五厘米/ 2022年08月31日 06:48/ 0 赞/ 175 阅读

相关 Golang并发：一招掌握无阻塞通道读写

介绍Golang并发的模型写了几篇了，但一直没有以channel为主题进行介绍，今天就给大家聊一聊channel，channel的基本使用非常简单，想必大家都已了解，所以直接来

缺乏、安全感/ 2022年03月02日 19:12/ 0 赞/ 261 阅读

相关读写 channel 实战

一实战 1 需求创建一个 intChan，最多可以存放3个int，演示存3个数据到 intChan，然后再取出这3个int。 2 代码 pa

左手的ㄟ右手/ 2021年07月24日 14:06/ 0 赞/ 382 阅读