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

释放双眼,带上耳机,听听看~!

// 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的原创作品,如需转载,请注明出处,否则将追究法律责任

【转自慕课】https://www.imooc.com

Go

golang-字符串

2022-3-3 14:26:20

Go

GO 语言的修饰器编程

2022-3-3 14:33:25

搜索