1

Go select多路复用, 实现超时机制

 2 years ago
source link: https://forrestsu.github.io/posts/go/select-in-go/
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.

Go select多路复用, 实现超时机制

2019年12月18日
| 字数 892
| Go
| 阅读 77

1 Preface

我们在 Linux 服务端编程的时候，select/epoll 可以监控多个fd, 并且可以指定超时时间。 那么我们在Go 里面也有select 关键字，那么怎么实现超时机制呢？

在 select 中加入一个 timer channel

case rc2 := <-time.After(d):

After等待持续时间过去，然后在返回的通道上发送当前时间。 它等效于NewTimer(d)。 在计时器触发之前，底层的计时器不会由垃圾收集器恢复。 如果需要提高效率，请改用NewTimer，如果不再需要计时器，请调用Timer.Stop。

完整代码如下：

// 采用 select 实现超时
func TestSelectTimeOut(t *testing.T) {
    ch01 := make(chan int)
    go func(ch01 chan int) {
        fmt.Println("enter co-routine...")
        isRunning := true
        for isRunning {
            select {
            case rc1, ok := <-ch01:
                fmt.Println("rc1", rc1)
                if ok == false {
                    isRunning = false
                    fmt.Println("channel closed")
                }
            case rc2 := <-time.After(time.Millisecond * 200):
                fmt.Println("time out 1 sec", rc2)
            }
        }
        fmt.Println("exit co-routine...")
    }(ch01)
    time.Sleep(time.Second * 2)
    // 2秒之后发送一个消息
    ch01 <- 10
    close(ch01)
}

Go 语言通过 channel 实现了很强大的功能, 使得编程更灵活易用，降低了学习门槛； 在 Linux C 里面高效的做法，采用epoll去做timer 的等待。

那么 Go 里面的 timer 的实现原理是怎样的呢? 且听后续分解。

《全文完》


report

Recommend

About Joyk


Aggregate valuable and interesting links.
Joyk means Joy of geeK