Golang语言并行设计的核心goroutine

栏目: Go · 发布时间: 5年前

内容简介:goroutine实现并发编程,goroutine之间通信使用channel,channel不管是发送数据还是接收数据都是阻塞的,channel默认无缓冲,但也可以指定缓冲大小变成有缓冲,空间有剩余时是无阻塞,直到空间全部用完时才阻塞。

goroutine实现并发编程,goroutine之间通信使用channel,channel不管是发送数据还是接收数据都是阻塞的,channel默认无缓冲,但也可以指定缓冲大小变成有缓冲,空间有剩余时是无阻塞,直到空间全部用完时才阻塞。

/**
 * goroutine实现并发编程
 * goroutine之间通信使用channel
 * channel不管是发送数据还是接收数据都是阻塞的
 * channel默认无缓冲,但也可以指定缓冲大小变成有缓冲,空间有剩余时是无阻塞,直到空间全部用完时才阻塞
 */
package main

import (
    "fmt"
)

func sum(a []int, c chan int) {
    total := 0
    for _, v := range a {
        total += v
    }
    // 发送total到c
    c <- total
}
func fibonacci(n int, c chan int) {
    x, y := 1, 1
    for i := 0; i < n; i++ {
        // 发送x到c
        c <- x
        x, y = y, x+y
    }
    // 通过内置函数close关闭channel
    close(c)
}
func main() {
    a := []int{9, 2, 6, -5, 3, 0}
    // 使用make创建channel,默认无缓冲,阻塞
    c := make(chan int)
    // 使用 go 关键字启动goroutine
    go sum(a[:len(a)], c)
    go sum(a[len(a)/2:], c)
    // 从c中接收数据
    x, y := <-c, <-c
    fmt.Println(x, y, x+y)
    // 使用make创建有缓冲的channel,空间有剩余时是无阻塞,直到空间全部用完时才阻塞
    // 修改2为1则报错,修改2为3则正常
    c1 := make(chan int, 2)
    c1 <- 1
    c1 <- 2
    fmt.Println(<-c1)
    fmt.Println(<-c1)
    c2 := make(chan int, 10)
    // 使用go关键字启动goroutine
    go fibonacci(cap(c2), c2)
    // 使用range读取channel
    for i := range c2 {
        fmt.Println(i)
    }
}

以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

The Lean Startup

The Lean Startup

Eric Ries / Crown Business / 2011-9-13 / USD 26.00

更多中文介绍:http://huing.com Most startups fail. But many of those failures are preventable. The Lean Startup is a new approach being adopted across the globe, chan ging the way companies are built and ......一起来看看 《The Lean Startup》 这本书的介绍吧!

HTML 压缩/解压工具
HTML 压缩/解压工具

在线压缩/解压 HTML 代码

JS 压缩/解压工具
JS 压缩/解压工具

在线压缩/解压 JS 代码

SHA 加密
SHA 加密

SHA 加密工具