golang 非阻塞使用channel 示例

package main

import "fmt"

func main() {
    messages := make(chan string)
    signals := make(chan bool)

    /**
    这里是一个非阻塞 receive。如果在 messages 上的值是可用的，
    那 select 将 <-messages 的值带上，执行 <-messages 下面的println语句。
    如果不是，它将立即带上 default 的值，执行 default 下面的println语句
    **/
    select {
    case msg := <-messages:
        fmt.Println("received message", msg)
    default:
        fmt.Println("no message received")
    }
    /**
    一个非阻塞 send 的类似工作
    **/
    msg := "hi"
    select {
    case messages <- msg:
        fmt.Println("sent message", msg)
    default:
        fmt.Println("no message sent")
    }

    /**
    我们可以用在 default 之上使用多个 cases 来实现一个非阻塞的多路 select。
    在这里我们尝试在 messages 和 signals 上实现非阻塞 receives。
    **/

    select {
    case msg := <-messages:
        fmt.Println("received message", msg)
    case sig := <-signals:
        fmt.Println("received signal", sig)
    default:
        fmt.Println("no activity")
    }
}

Be the first to comment!

Submit

Relative Articles

• Golang 给运行中的goroutine 发送终止信号
  goroutine 运行机制是不能外部终止，只能通过 channel 来与它通信，通过 channel 给goroutine 发送终止信号
  Read On →
• Golang 并发控制的两种模式
  两种常用的并发控制，使用channel 和 WaitGroup
  Read On →
• golang 通过channel 实现协程间通信
  golang 通过channel 实现协程间通信 ``` import ( "fmt" "time" ) func worker(done chan bool) { time.Sleep(time.Second) // 通知任务已完成 done <- true } func main() { done := make(chan bool, 1) go worker(done) // 等待任务完成 <-done } ```
  Read On →
• golang channel 读写超时处理
  Go 语言的 channel 本身是不支持 timeout 的，所以一般实现 channel 的读写超时都采用 select
  Read On →
• golang共享数据用Mutex 或 Channel
  在go 里，多线程对共享数据的操作一般要使用Mutex 或 Channel 来加锁或隔离通信。下面是一个使用Mutex 和 Channel 比较的例子。
  Read On →