什么是channel
channel是Go语言在语言级别提供的goroutine间的通信方式。我们可以使用channel在两个或 多个goroutine之间传递消息。channel是进程内的通信方式，因此通过channel传递对象的过程和调用函数时的参数传递行为比较一致，比如也可以传递指针等。如果需要跨进程通信，我们建议用 分布式系统的方法来解决，比如使用Socket或者HTTP等通信协议。Go语言对于网络方面也有非常完善的支持。 channel是类型相关的。也就是说，一个channel只能传递一种类型的值，这个类型需要在声明channel时指定。如果对Unix管道有所了解的话，就不难理解channel，可以将其认为是一种类 型安全的管道。
并发编程中各线程的一种通信机制
代码：
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里的数据放到数组，循环输出。
我写的测试代码
package main
import (
"fmt"
"time"
)
func sum(arrars []int, ch chan int) {
sleepTime()
sum := 0
for _, array := range arrars {
sum += array
fmt.Printf("->%d", sum)
}
ch <- sum
}
//sleep 单位s
func sleepTime() {
time.Sleep(time.Second * 2)
fmt.Println("time sleep 10s end")
}
func main() {
arrayChan := make(chan int, 20)
arrayInt := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15}
fmt.Printf("%v", arrayInt)
for t := 0; t < 10; t++ {
length := len(arrayInt)
fmt.Println(arrayInt[length-t:])
go sum(arrayInt[length-t:], arrayChan)
}
arrayResult := [10]int{0}
for i := 0; i < 10; i++ {
arrayResult[i] = <-arrayChan
}
fmt.Println(arrayResult)
}
备注以及引用
原文Golang 简单理解Channel