一文带你掌握Golang基础之通道

 更新时间:2023年05月05日 11:09:12   作者:Mars酱  
在Java中,多线程之间的通信方式有哪些?记得吗?Java多线程间通信的解决方案有很多种,比如:synchronized。在go中,就一种:通道,文中介绍的非常详细,感兴趣的同学可以参考下

前言

在Java中,多线程之间的通信方式有哪些?记得吗?Java多线程间通信的解决方案有很多种,比如:synchronized。使用锁来防止资源乱来,一人一个按顺序来,要么使用JDK提供的原子对象,那些Atomic关键字开头的对象,比如:AtomicInteger,这样可以在多个线程中读写值的时候保证是安全的,还有很多其他的方式,在go中,就一种:通道

通道

go的通道我根据java的理解,它就是用来解决线程之间通信的东西,go里面的关键字叫channels

以下是搜索出来的解释:

go语言提倡使用通信的方法代替共享内存,当一个资源需要在 goroutine 之间共享时,通道在 goroutine 之间架起了一个管道,并提供了确保同步交换数据的机制。声明通道时,需要指定将要被共享的数据的类型。可以通过通道共享内置类型、命名类型、结构类型和引用类型的值或者指针。这里通信的方法就是使用通道(channel),如下图所示:

图:goroutine 与 channel 的通信

是不是和java的线程安全对象是类似?或者说是队列?总之你可以按照你自己经验去理解。

如何创建通道

go提供了创建通道的语法:

通道变量名 := make(chan 数据类型)

比如,我们可以这样写:

// 创建一个int型的通道
ch1 := make(chan int)

还可以创建一个接口类型通道,比如:

ch2 := make(chan interface{})

还能创建一个结构体的通道,比如:

// 创建一个User结构体的通道,这个通道是个指针通道
ch3 := make(chan *User)

向通道发送数据

go向通道发送数据语法非常简单:

通道变量名 <- 值

 我们向上面三个通道名发送数据,可以写成:

// 1. 给ch1通道传值0
ch1 <- 0
// 2. 给ch2通道传字符串,实际可以穿任意对象,因为前面声明了是interface对象
ch2 <- "hello, mars酱"

// 创建一个userInfo结构体并初始化值
userInfo := User{
	1, "mars酱",
}
// 3. 发送一个结构体到通道ch3中
ch3 <- &userInfo

以上代码是无法运行的,因为go的通道有个规矩,发送和接收必须成对出现,不信邪的可以验证一下。

从通道接收数据

go从通道中接收数据的语法也简单:

data := <- ch1

这个语句是个阻塞语句,只有当data接收到了值,才会执行后续的,非阻塞的这样写:

data, ok := <- ch1

data:接收的数据,如果没有接收到,data为0。data为0取决于之前make通道的时候,ch1是个int型通道,如果是其他类型,这个data也应该是其他类型对象;

ok:boolean类型的值,表示是否接收到数据

还有个奇葩的写法:

<- ch1

这样写就表示通道里有啥都与我无关,忽略掉了。

通道的例子

一个倒数的例子,通过通道去实现一下:

// author: mars酱
func Test_chanTest(t *testing.T) {
	// 1. 创建一个通道
	ch1 := make(chan int)
	// 2. 启动goroutine并发
	go func() {
		// 从5 到 0
		for i := 5; i >= 0; i-- {
			// 3. 发送给通道
			ch1 <- i
			// 发完后等1秒
			time.Sleep(time.Second)
		}
	}()
	// 4. 循环接收通道数据
	for data := range ch1 {
		fmt.Println(data)
		if data == 0 {
			break
		}
	}
}

运行的结果:

发射火箭的倒数计时就是这样吧~

以上就是一文带你掌握Golang基础之通道的详细内容,更多关于Golang通道的资料请关注脚本之家其它相关文章!

相关文章

  • golang如何自定义json序列化应用详解

    golang如何自定义json序列化应用详解

    son格式可以算我们日常最常用的序列化格式之一了,下面这篇文章主要给大家介绍了关于golang如何自定义json序列化应用的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考借鉴,下面来一起看看吧
    2018-08-08
  • Golang中互斥锁和读写互斥锁原理及示例代码

    Golang中互斥锁和读写互斥锁原理及示例代码

    在Golang中,互斥锁是一种基本的同步原语,用于实现对共享资源的互斥访问,读写互斥锁是一种特殊类型的互斥锁,它允许多个协程同时读取某个共享资源,本文将通过过示例代码详细介绍Golang中互斥锁和读写互斥锁,需要的朋友可以参考下
    2023-05-05
  • Golang中errgroup的常见误用详解

    Golang中errgroup的常见误用详解

    errgroup和sync.WaitGroup类似,都可以发起执行并等待一组协程直到所有协程运行结束,本文主要为大家整理了一些errgroup的常见误用,有需要的可以参考下
    2024-01-01
  • go mayfly开源项目代码结构设计

    go mayfly开源项目代码结构设计

    这篇文章主要为大家介绍了go mayfly开源项目代码结构设计详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-11-11
  • 深入探索Go语言中unsafe包的使用

    深入探索Go语言中unsafe包的使用

    Go语言的unsafe包被誉为黑科技,它为Go语言提供了底层访问和操控内存的能力,本文将深入探讨Go语言中unsafe包的使用方法和注意事项,需要的可以参考一下
    2023-04-04
  • golang连接kafka消费进ES操作

    golang连接kafka消费进ES操作

    这篇文章主要介绍了golang连接kafka消费进ES操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-12-12
  • Golang Http请求返回结果处理

    Golang Http请求返回结果处理

    本文主要介绍了Golang Http请求返回结果处理,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-08-08
  • Go语言中log日志库的介绍

    Go语言中log日志库的介绍

    本文给大家介绍Go语言中log日志库的概念使用技巧,log包定义了Logger类型,该类型提供了一些格式化输出的方法,本文通过示例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧
    2021-10-10
  • 详解如何热重启golang服务器

    详解如何热重启golang服务器

    这篇文章主要介绍了详解如何热重启golang服务器,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-08-08
  • Go检查结构体中是否存在某个字段及创建结构体切片或映射

    Go检查结构体中是否存在某个字段及创建结构体切片或映射

    这篇文章主要为大家介绍了Go检查结构体中是否存在某个字段及创建结构体切片或映射实现示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2024-01-01

最新评论