golang chan初始化

admin 2024-10-16 22:46:06 编程 来源:ZONE.CI 全球网 0 阅读模式

作为一名专业的golang开发者,我深知chan在并发编程中的重要性和使用场景。在本文中,我将详细介绍golang中chan的初始化方法以及相关注意事项。

无缓冲和有缓冲的chan初始化

在golang中,我们可以通过make函数来初始化chan,并指定其大小。当我们不指定大小时,就创建了一个无缓冲的chan;反之则创建了一个有缓冲的chan。下面是示例代码:

package main

import "fmt"

func main() {
	// 初始化无缓冲chan
	ch := make(chan int)
	// 初始化有缓冲chan
	chBuf := make(chan int, 10)
	
	go func() {
		// 发送数据到无缓冲chan
		ch <- 1="" 发送数据到有缓冲chan="" chbuf=""><- 2="" }()="" 从无缓冲chan接收数据="" data1="" :=""><-ch fmt.println(data1)="" 从有缓冲chan接收数据="" data2="" :=""><-chbuf fmt.println(data2)="" }="">

上述代码中,我们用make函数初始化了无缓冲的chan ch 和有缓冲大小为10的chan chBuf。随后,我们使用go func开启了一个新的goroutine,在其中分别向这两个chan发送了数据。接着,我们使用<-ch<-chBuf分别从这两个chan接收了数据,并打印输出。

chan的阻塞和非阻塞模式

在golang中,向无缓冲的chan发送数据操作和从无缓冲的chan接收数据操作都是阻塞的。这意味着,发送方将会阻塞直到接收方接收到数据,而接收方也会阻塞直到发送方发送了数据。下面是示例代码:

func sendData(ch chan int) {
  ch <- 1="" }="" func="" main()="" {="" ch="" :="make(chan" int)="" 发送方阻塞,等待接收方接收数据="" go="" senddata(ch)="" 接收方阻塞,等待发送方发送数据="" data="" :=""><-ch fmt.println(data)="" }="">

上述代码中,我们定义了一个sendData函数,该函数向chan发送数据。在主函数中,我们创建了一个无缓冲的chan ch,然后我们通过go sendData(ch)开启了一个新的goroutine来发送数据。接着,我们使用<-ch从chan中接收了数据,并打印输出。

如果我们想要实现非阻塞的chan操作,可以借助select语句和default分支。例如,我们可以使用select语句来同时监听多个chan,一旦其中某个chan可读或可写,我们就可以执行相应的操作。

package main

import (
	"fmt"
	"time"
)

func main() {
	ch1 := make(chan int)
	ch2 := make(chan int)

	go func() {
		time.Sleep(time.Second * 2)
		ch1 <- 1="" }()="" go="" func()="" {="" time.sleep(time.second="" *="" 3)="" ch2=""><- 2="" }()="" select="" {="" case="" data="" :=""><-ch1: fmt.println("收到来自ch1的数据:",="" data)="" case="" data="" :=""><-ch2: fmt.println("收到来自ch2的数据:",="" data)="" default:="" fmt.println("没有收到任何数据")="" }="" }="">

上述代码中,我们创建了两个chan ch1ch2,然后分别开启了两个新的goroutine,并在不同的时间向这两个chan发送数据。接着,我们使用select语句监听这两个chan,一旦其中一个chan中有可读数据,就会执行对应的case块。如果这两个chan都没有可读数据,就会执行default分支。

chan的关闭和遍历

在golang中,我们可以通过close函数来关闭chan。关闭chan后,我们还可以继续从其中接收数据,但不能再向其发送数据。另外,chan关闭后,接收方如果没有数据可读,会立即返回zero-value

package main

import "fmt"

func send(ch chan int) {
	for i := 0; i < 5; i++ {
		ch <- i="" }="" close(ch)="" }="" func="" main()="" {="" ch="" :="make(chan" int)="" go="" send(ch)="" for="" data="" :="range" ch="" {="" fmt.println("接收到数据:",="" data)="" }="" }="">

上述代码中,我们定义了一个send函数,该函数往chan中发送一系列数据,然后通过close(ch)方式关闭chan。在主函数中,我们使用for range循环来遍历chan,一直接收数据直到chan关闭。打印输出的结果是接收到的数据。

在以上三个方面,我们对golang中chan的初始化和使用进行了详细介绍。不论是无缓冲还是有缓冲的chan,都有自己的适用场景。在并发编程中,chan是非常重要的一种通信机制,它能够有效地协调goroutine的执行顺序和数据交换。因此,熟练掌握chan的初始化和使用方法,对于成为一名高效的golang开发者至关重要。

以太坊cppgolang区别 编程

以太坊cppgolang区别

以太坊是一种去中心化的开源平台,它采用智能合约技术,旨在构建和运行不受干扰的分布式应用程序。作为目前最受欢迎的区块链平台之一,以太坊提供了多种编程语言的支持,其
progolang 编程

progolang

Go语言(Golang)是由Google开发的一门静态类型编程语言。作为一名专业的Golang开发者,我深知这门语言的优势和特点。在本文中,我将介绍Golang
golangn个发送者 编程

golangn个发送者

Golang是一种开源的编程语言,由Google团队开发,旨在提高程序的并发性和简化软件开发过程。在Go语言中,有时需要向多个接收者发送信息。本文将介绍如何在G
golang技能图谱 编程

golang技能图谱

从互联网行业的快速发展到人工智能技术的日益成熟,各种编程语言也应运而生。而在这众多的编程语言中,Golang(即Go)作为一门强大且高效的开发语言备受关注。Go
评论:0   参与:  31