golang中select实现非阻塞及超时控制

PowerMichael · · 1774 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

// select.go
package main

import (
    "fmt"
    "time"

    //"time"
)

func main() {
    //声明一个channel
    ch := make(chan int)

    //声明一个匿名函数,传入一个参数整型channel类型ch
    go func(ch chan int) {
        ch <- 1
        //往channel写入一个数据,此时阻塞
    }(ch)

    //由于goroutine执行太快,先让它sleep 1秒
    time.Sleep(time.Second)

    select {
    //读取ch,解除阻塞
    case <-ch:
        fmt.Print("come to read ch!")
    default:
        fmt.Print("come to default!")
    }
}

// select.go
//整型channel类型ch一直处于读取状态,所以处于阻塞,使用select实现超时控制
package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)
    //buffer channel,1个元素前非阻塞
    timeout := make(chan int, 1)

    go func() {
        time.Sleep(time.Second)
        //写channel
        timeout <- 1
    }()

    select {
    //读channel
    case <-ch:
        fmt.Print("come to read ch!")
        //没有读到channel,实现超时控制
    case <-timeout:
        fmt.Print("come to timeout!")
    }

    fmt.Print("end of code!")
}

// select.go
//使用time.After实现超时控制
package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)

    select {
    case <-ch:
        fmt.Print("come to read ch!")
    case <-time.After(time.Second):
        fmt.Print("come to timeout!")
    }

    fmt.Print("end of code!")
}

有疑问加站长微信联系(非本文作者)

本文来自:51CTO博客

感谢作者:PowerMichael

查看原文:golang中select实现非阻塞及超时控制

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1774 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传