Golang 简单理解Channel

未来还没来 · · 28119 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

什么是channel?

        channel是Go语言在语言级别提供的goroutine间的通信方式。我们可以使用channel在两个或 多个goroutine之间传递消息。channel是进程内的通信方式,因此通过channel传递对象的过程和调用函数时的参数传递行为比较一致,比如也可以传递指针等。如果需要跨进程通信,我们建议用 分布式系统的方法来解决,比如使用Socket或者HTTP等通信协议。Go语言对于网络方面也有非常完善的支持。 channel是类型相关的。也就是说,一个channel只能传递一种类型的值,这个类型需要在声明channel时指定。如果对Unix管道有所了解的话,就不难理解channel,可以将其认为是一种类 型安全的管道。

(我复制pdf上的。个人理解即是并发编程中各线程的一种通信机制


代码:

package main

import "fmt"

func sum(values []int, resultChan chan int) {
    sum := 0
    for _, value := range values {
        sum += value
    }
    // 将计算结果发送到channel中
    resultChan <- sum
}
func main() {
    values := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}
    resultChan := make(chan int, 3)
    go sum(values[:len(values)/2], resultChan)
    go sum(values[len(values)/2:], resultChan)
    go sum(values[len(values)/3:], resultChan)
    sum1, sum2, sum3 := <-resultChan, <-resultChan, <-resultChan
    fmt.Println("Result:", sum1, sum2, sum3)
}


sum函数

2个参数,一个是int数组,一个是int类型的chan~~~函数里面即使把传递过来的数组进行逐个元素相加,不说了。 

后面的resultChan <- sum 这里则是把我们相加的结果赋值到resultChan里面


主函数

values := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}

这里则是定义一个int数组

resultChan := make(chan int, 3)

声明一个int类型的chan,大小为3

go sum(values[:len(values)/2], resultChan)

取一半的values数组,resultChan。然后启动一个线程去访问sum函数

go sum(values[len(values)/2:], resultChan)

取一半的values数组,resultChan。然后启动一个线程去访问sum函数

go sum(values[len(values)/3:], resultChan)

计算数组的长度10,然后除3。无限循环3.333333~,系统自动取3,后面的冒号作用取第3个元素后面的数据

    sum1, sum2, sum3 := <-resultChan, <-resultChan, <-resultChan

把resultChan的值赋给sum1,sum2,sum3。依照线程执行顺序

fmt.Println("Result:", sum1, sum2, sum3)

输出结果


怎么用chan?


写个简单的example好了。

package main

import "fmt"

func sum(arrays []int, ch chan int) {
    //fmt.Println(arrays)
    sum := 0
    for _, array := range arrays {
        sum += array
    }
    ch <- sum
}

func main() {
    arrayChan := make(chan int, 20)
    arrayInt := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15}
    for t := 0; t < 10; t++ {
        length := len(arrayInt)
        go sum(arrayInt[length-t:], arrayChan)
    }

    arrayResult := [10]int{0}
    for i := 0; i < 10; i++ {
        arrayResult[i] = <-arrayChan
    }
    fmt.Println(arrayResult)
}

大概内容就是,声明一个chan,然后启动10个线程,把运算结果放到chan里,最后把chan里的数据放到数组,循环输出。


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

本文来自:开源中国博客

感谢作者:未来还没来

查看原文:Golang 简单理解Channel

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

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