channel

柔光的暖阳◎ 2022-06-12 07:10 246阅读 0赞

### channel阻塞读 channel阻塞写 ###

c := make(chan int)
    go func() {
        time.Sleep(time.Second * 3)
        fmt.Println("Write:", 1)
        c <- 1 // 阻塞写
    } ()
    fmt.Println("Reading")
    fmt.Println("Read:", <- c) // 阻塞读

### channel缓冲读 channel缓冲写 ###

c := make(chan int, 3)
    c <- 1 // 缓冲写
    c <- 2 // 缓冲写
    c <- 3 // 缓冲写
    fmt.Println(<- c) // 缓冲读
    fmt.Println(<- c) // 缓冲读
    fmt.Println(<- c) // 缓冲读

### channel非阻塞读 channel非阻塞写 ###

c := make(chan int)
    // 读超时
    select {
    case <- c:
    case <-time.After(time.Second):
        fmt.Println("timeout")
    }
    // 写超市
    select {
    case c <- 1:
    case <-time.After(time.Second):
        fmt.Println("timeout")
    }

### channel非阻塞读 channel非阻塞写 ###

c := make(chan int)
    // 非阻塞读取
    select {
    case <- c:
    default:
    }
    fmt.Println("non-blocking")
    // 非阻塞写
    select {
    case c <- 1:
    default:
    }
    fmt.Println("non-blocking")

### channel只读 channel只写 ###

c := make(chan int, 2)
    // channel只写
    var cw chan<- int = c
    cw <- 1
    cw <- 2
    // channel只读
    var cr <-chan int = c
    fmt.Println(<- cr)
    fmt.Println(<- cr)

### channel读取 ###

for v := range c {} // channel关闭,for循环自动退出
    for { v := <- c } // channel关闭,for不会退出
    for { v, isClose := <- c } // dotcoo关闭,需要手动判断退出for循环

### channel关闭 ###

c := make(chan int)
    close(c)
    v, isClose := <- c

发表评论取消回复

表情：

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

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

相关阅读

相关 Channel

hannel是network socket或能够执行IO操作(如read,write,connect,bind)的组件的纽带。 Channel为用户提供：通道的当前...

红太狼/ 2024年04月17日 06:25/ 0 赞/ 77 阅读

相关 Channel shutdown: channel error； protocol method: #method＜channel.close＞(reply-code=406, reply-text=

[RabbitMq][RabbitMq]重复签收问题 Channel shutdown: channel error; protocol method: meth

系统管理员/ 2023年10月08日 19:44/ 0 赞/ 64 阅读

相关 [rabbitmq] Channel shutdown: channel error； protocol method: #method＜channel.close＞(reply-code=406

rabbitmq 报错日志： > 2021-05-08 15:30:00,023 ---\[ visitor \]--- ERROR \[AMQP Connection ip

左手的ㄟ右手/ 2023年01月19日 07:17/ 0 赞/ 19 阅读

相关 gRPC-Channel

gRPC Channel `Channel` 是用于执行 RPC 请求的概念上的端点连接，基于负载和配置，一个 `Channel` 可以有 0 或多个真实连接 `Sub

墨蓝/ 2022年10月22日 02:59/ 0 赞/ 235 阅读

相关 channel

channel阻塞读 channel阻塞写 c := make(chan int) go func() { time.Sleep(time

柔光的暖阳◎/ 2022年06月12日 07:10/ 0 赞/ 246 阅读

相关【NIO】Channel（通道）

前言 Github：[https://github.com/yihonglei/jdk-source-code-reading][https_github.com_yih

灰太狼/ 2022年05月31日 08:56/ 0 赞/ 364 阅读

相关 Channel 详解

　　java.nio.channels.FileChannel封装了一个文件通道和一个FileChannel对象，这个FileChannel对象提供了读写文件的连接。 1、

╰+攻爆jí腚メ/ 2021年11月16日 11:34/ 0 赞/ 434 阅读

相关 Go：channel

一、channel 在 Go 语言里，不仅可以使用原子函数和互斥锁来保证对共享资源的安全访问以及消除竞争状态，还可以使用 channel，通过发送和接收需要共享的资源，在

左手的ㄟ右手/ 2021年09月20日 09:16/ 0 赞/ 424 阅读

相关 flume之Channel

Channels 是一个 Agent上存储 events 的仓库，Source 向其中添加 events，而 Sink从中取走移除 events。本文重点介绍memory ch

た入场券/ 2021年06月24日 15:58/ 0 赞/ 584 阅读

相关 NIO之Channel

1、基本概念 Java NIO中，channel用于数据的传输，类似于传统BIO中的流（IOStream）的概念。我们都知道，系统的I/O都分为两个阶段：等

快来打我*/ 2021年06月22日 15:36/ 0 赞/ 529 阅读