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)
    }
}

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

查看所有标签

猜你喜欢:

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

第三次浪潮

第三次浪潮

[美]阿尔文·托夫勒 / 黄明坚 / 中信出版集团 / 2018-7 / 79.00元

《第三次浪潮》是美国著名未来学家阿尔文•托夫勒的代表作之一。1980年出版之际,随即引起全球热评,堪称中国改革开放的指南。本书阐述了由科学技术发展引起的社会各方面的变化与趋势。托夫勒认为,人类迄今为止已经经历了两次浪潮文明的洗礼:第一次是农业革命,人类就此从原始渔猎时代进入以农业为基础的文明社会,并历经千年,直到工业革命的到来。随后,人类社会历时300年摧毁了落后的第一次浪潮文明,并在“二战”后1......一起来看看 《第三次浪潮》 这本书的介绍吧!

随机密码生成器
随机密码生成器

多种字符组合密码

Base64 编码/解码
Base64 编码/解码

Base64 编码/解码

MD5 加密
MD5 加密

MD5 加密工具