Go语言:goroutine and channels

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

channels 在Golang中是一个具有类型的管道(conduit)

Channels are a typed conduit through which you can send and receive values with the channel operator, <-.

创建管道的方式很简单:

ch := make(chan int)  // declare a channel of type int
ch := make(chan int, 100)  // buffered channels
// Sends to a buffered channel block only when the buffer is full. 
// Receives block when the buffer is empty.
v, ok := <-ch  // ok is false if there are no more values to receive and the channel is closed.

当所有的 gorountine 都处于 asleep 状态的时候,程序报错。

我感觉Golang里的 channels 就类似于Python标准库的queue.Queue,但是比Python要安全和智能。

关闭管道,使用close函数。

循环 for i := range c 从管道中接收值直到管道被关闭。

下面是一个例子:

一个线程不断生成 fibonacci 数列,另一个线程不断去输出,两个线程用 channels 通信
package main
import (
    "fmt"
)

func fibonacci(n int, c chan int) {
    x, y := 1, 1
    for i := 0; i < n; i++ {
        c <- x
        x, y = y, x+y
    }
    close(c)
}

func main() {
    c := make(chan int, 10)
    go fibonacci(cap(c), c)
    for i := range c {
        fmt.Println(i)
    }
}

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

本文来自:简书

感谢作者:落落大方的发卡

查看原文:Go语言:goroutine and channels

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

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