登录
首页 >  Golang >  Go教程

golang channel管道使用示例解析

来源:脚本之家

时间:2023-01-07 11:59:32 452浏览 收藏

亲爱的编程学习爱好者,如果你点开了这篇文章,说明你对《golang channel管道使用示例解析》很感兴趣。本篇文章就来给大家详细解析一下,主要介绍一下channel、管道,希望所有认真读完的童鞋们,都有实质性的提高。

定义channel管道

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

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

channel管道塞值和取值

ch <- 666  //向ch管道塞入666
<- ch  // 向ch管道接收值,并丢弃
x := <-ch  //向ch管道中接收数据,并复制给x
x, ok := <-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 
<h2>无缓冲的channel</h2>
<blockquote><p>ch := make(chan int, 0)</p></blockquote>
<pre class="brush:groovy;">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 
<h2>有缓冲的channel管道</h2>
<blockquote><p>ch := make(chan int, 3)</p></blockquote>
<pre class="brush:groovy;">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 
<h2>关闭channel管道</h2>
<blockquote><p>close(ch)</p></blockquote>
<pre class="brush:groovy;">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 10 {
				close(ch)
				break
			}
		}
	}()
	go func() {
		for  {
			if num, ok := 
<h2>单向channel管道,读写分离</h2>
<blockquote><p>chan</p></blockquote>
<p>注意:双向可转为单向,单向不可转为双向</p>
<pre class="brush:groovy;">package main
//"fmt"
func main() {
	//创建一个channel, 双向的
	ch := make(chan int)
	//双向channel能隐式转换为单向channel
	var writeCh chan
<h2>管道消费者生产者模型</h2>
<pre class="brush:groovy;">package main
import (
	"fmt"
)
//此通道只能写,不能读
func producer(out chan
<p>理论要掌握,实操不能落!以上关于《golang channel管道使用示例解析》的详细介绍,大家都掌握了吧!如果想要继续提升自己的能力,那么就来关注golang学习网公众号吧!</p>
声明:本文转载于:脚本之家 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>
评论列表