golang channel管道使用示例解析

更新时间：2022年04月14日 14:28:37 作者：Jeff的技术栈

这篇文章主要介绍了golang channel管道使用示例解析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步早日升职加薪

定义channel管道

定义一个channel时，也需要定义发送到管道的值类型。channel可以使用内置的make()函数来创建：

var ch = make(chan int) //等价于：make(chan Type,0)
var ch = make(chan Type,capacity)

channel管道塞值和取值

ch &lt;- 666  //向ch管道塞入666
&lt;- ch  // 向ch管道接收值，并丢弃
x := &lt;-ch  //向ch管道中接收数据，并复制给x
x, ok := &lt;-ch  //向ch管道中接收数据，并复制给x,同时检查通道是否已关闭或者是否为空

当capacity=0时，channel管道是无缓冲阻塞读写，
当capacity>0时，channel管道有缓冲，是非阻塞的，直到写满capacity个元素才阻塞写入。

注意：默认情况下，channel接收和发送数据都是阻塞的，除非另一端已经准备好，这样就使得goroutine同步变得更加简单，而不需要显示的lock。

通过channel管道实现同步，和数据交互

package main
import (
	"fmt"
	"time"
)
func main() {
	//创建channel
	ch := make(chan string)
	defer fmt.Println("主协程也结束")
	go func() {
		defer fmt.Println("子协程调用完毕")
		for i := 0; i < 2; i++ {
			fmt.Println("子协程 i = ", i)
			time.Sleep(time.Second)
		}
		ch <- "我是子协程，要工作完毕"
	}()
	str := <-ch //没有数据前，阻塞
	fmt.Println("str = ", str)
}

无缓冲的channel

ch := make(chan int, 0)

package main
import (
	"fmt"
	"time"
)
func main() {
	//创建一个无缓存的channel
	ch := make(chan int, 0)

	//len(ch)缓冲区剩余数据个数， cap(ch)缓冲区大小
	fmt.Printf("len(ch) = %d, cap(ch)= %d\n", len(ch), cap(ch))
	//新建协程
	go func() {
		for i := 0; i < 10000; i++ {
			fmt.Printf("子协程：i = %d\n", i)
			ch <- i //往chan写内容
			time.Sleep(1 * time.Second)
		}
	}()
	go func() {
		for  {
			num := <-ch //读管道中内容，没有内容前，阻塞
			fmt.Println("num = ", num)
		}

	}()
	for {
	}
}

有缓冲的channel管道

ch := make(chan int, 3)

package main
import (
	"fmt"
	"time"
)
func main() {
	//创建一个有缓存的channel
	ch := make(chan int, 3)
	//len(ch)缓冲区剩余数据个数， cap(ch)缓冲区大小
	fmt.Printf("len(ch) = %d, cap(ch)= %d\n", len(ch), cap(ch))
	//新建协程
	go func() {
		for i := 0; i < 10; i++ {
			ch <- i //往chan写内容
			fmt.Printf("子协程[%d]: len(ch) = %d, cap(ch)= %d\n", i, len(ch), cap(ch))
		}
	}()
	//延时
	time.Sleep(2 * time.Second)
	for i := 0; i < 10; i++ {
		num := <-ch //读管道中内容，没有内容前，阻塞
		fmt.Println("num = ", num)
	}
}

关闭channel管道

close(ch)

package main
import (
	"fmt"
)
func main() {
	//创建一个无缓存的channel
	ch := make(chan int, 3)
	//len(ch)缓冲区剩余数据个数， cap(ch)缓冲区大小
	fmt.Printf("len(ch) = %d, cap(ch)= %d\n", len(ch), cap(ch))
	//新建协程
	go func() {
		for i := 0; i < 10000; i++ {
			fmt.Printf("子协程：i = %d\n", i)
			ch <- i //往chan写内容
			//time.Sleep(1 * time.Second)
			if i >10 {
				close(ch)
				break
			}
		}
	}()
	go func() {
		for  {
			if num, ok := <-ch; ok == true {
				fmt.Println("num = ", num)
			} else { //管道关闭
				break
			}
		}
	}()
	for {

	}
}

单向channel管道,读写分离

chan<- 表示数据进入管道，只写
<-chan 表示数据从管道出来，只读

注意：双向可转为单向，单向不可转为双向

package main
//"fmt"
func main() {
	//创建一个channel, 双向的
	ch := make(chan int)
	//双向channel能隐式转换为单向channel
	var writeCh chan<- int = ch //只能写，不能读
	var readCh <-chan int = ch  //只能读，不能写
	writeCh <- 666 //写
	//<-writeCh //err,  invalid operation: <-writeCh (receive from send-only type chan<- int)
	<-readCh //读
	//readCh <- 666 //写， err,  invalid operation: readCh <- 666 (send to receive-only type <-chan int)
	//单向无法转换为双向
	//var ch3 chan int = writeCh //cannot use writeCh (type chan<- int) as type chan int in assignment

}

管道消费者生产者模型

package main
import (
	"fmt"
)
//此通道只能写，不能读
func producer(out chan<- int) {
	for i := 0; i < 10; i++ {
		out <- i * i  //写入
	}
	close(out)  //关闭
}
//此channel只能读，不能写
func consumer(data <-chan int) {
	for num := range data {
		fmt.Println("num = ", num)
	}
}
func main() {
	//创建一个双向通道
	ch := make(chan int)
	//生产者，生产数字，写入channel
	//新开一个协程
	go producer(ch) //channel传参，引用传递
	//消费者，从channel读取内容，打印
	consumer(ch)
}

以上就是golang channel管道的详细内容，更多关于channel管道的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

手把手带你走进Go语言之类型转换
每个函数都可以强制将一个表达式转换成某种特定数据类型，本文给大家介绍了在Go语言中类型转换的具体用法，讲述的非常详细，对大家的学习或工作具有一定的参考借鉴价值
2021-09-09
详解Go语言中Goroutine退出机制的原理及使用
goroutine是Go语言提供的语言级别的轻量级线程，在我们需要使用并发时，我们只需要通过 go 关键字来开启 goroutine 即可。本文就来详细讲讲Goroutine退出机制的原理及使用，感兴趣的可以了解一下
2022-07-07
GoLang channel底层代码分析详解
Channel和goroutine的结合是Go并发编程的大杀器。而Channel的实际应用也经常让人眼前一亮，通过与select，cancel，timer等结合，它能实现各种各样的功能。接下来，我们就要梳理一下GoLang channel底层代码实现
2022-10-10
Go语言中普通函数与方法的区别分析
这篇文章主要介绍了Go语言中普通函数与方法的区别,以实例形式对比分析了普通函数与方法使用时的区别与相关技巧,需要的朋友可以参考下
2015-02-02
使用Go语言实现简单聊天系统
本文介绍了如何使用Go语言和WebSocket技术构建一个简单的多人聊天室系统,包括客户端连接管理、消息广播和并发处理,最后,通过编写main.go、hub.go和client.go等核心代码模块,具有一定的参考价值,感兴趣的可以了解一下
2024-10-10
Golang使用原生http实现中间件的代码详解
中间件（middleware）：常被用来做认证校验、审计等,家常用的Iris、Gin等web框架,都包含了中间件逻辑,但有时我们引入该框架显得较为繁重,本文将介绍通过golang原生http来实现中间件操作,需要的朋友可以参考下
2024-05-05
一文带你了解Go语言如何解析JSON
本文将说明如何利用 Go 语言将 JSON 解析为结构体和数组，如果解析 JSON 的嵌入对象，如何将 JSON 的自定义属性名称映射到结构体，如何解析非结构化的 JSON 字符串
2023-01-01
go 迭代string数组操作 go for string[]
这篇文章主要介绍了go 迭代string数组操作 go for string[]，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-12-12
Go语言range关键字循环时的坑
今天小编就为大家分享一篇关于Go语言range关键字循环时的坑，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧
2019-03-03
Go语言依赖管理三要素示例解析
这篇文章主要介绍了Go语言依赖管理三要素及示例解析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-01-01