使用通道和模式

news/2024/11/8 5:50:00/

在这里插入图片描述

通过通道、选择语句和最佳实践掌握 Go 中的并发编程

并发编程是构建高效和响应迅速的软件的强大范例。Go，也被称为 Golang，通过通道提供了一种健壮且优雅的解决方案来进行并发通信。在这篇文章中，我们将探讨通道的概念、它们在并发编程中的作用，以及如何使用无缓冲和有缓冲的通道发送和接收数据。

通道简介

在 Go 中，通道是一种基本特性，它们使 Goroutines（并发执行的线程）之间能够进行安全和同步的通信。它们作为数据在 Goroutines 之间传递的通道，有助于并发程序的协调和同步。

通道是单向的，这意味着它们可以用于发送数据（<- chan）或接收数据（chan <-）。这种单向性有助于在 Goroutines 之间确立明确和受控的数据流。

发送和接收数据

1. 无缓冲通道

无缓冲通道 是一种数据同时发送和接收的通道类型。当在无缓冲通道上发送一个值时，发送者会阻塞，直到有一个相应的接收者准备好接收数据。同样，接收者会阻塞，直到有数据可用于接收。

以下是一个说明使用无缓冲通道的示例：

package mainimport ("fmt""time"
)func main() {ch := make(chan int) // Create an unbuffered channelgo func() {ch <- 42 // Send data into the channel}()time.Sleep(time.Second) // Give the Goroutine time to executevalue := <-ch // Receive data from the channelfmt.Println("Received:", value)
}

在这个示例中，一个 Goroutine 向无缓冲通道 ch 发送值 42，然后主 Goroutine 进行接收。程序将会阻塞，直到发送者和接收者都准备好。

2. 有缓冲通道

有缓冲通道 允许你使用指定的缓冲区大小异步地发送和接收数据。这意味着只要缓冲区没有满，你就可以向通道发送多个值而无需等待接收者。同样地，只要缓冲区不为空，接收者也可以从通道中读取数据而无需等待发送者。

以下是一个说明使用有缓冲通道的示例：

package mainimport "fmt"func main() {ch := make(chan string, 2) // Create a buffered channel with a capacity of 2ch <- "Hello" // Send data into the channelch <- "World"fmt.Println(<-ch) // Receive data from the channelfmt.Println(<-ch)
}

在这个示例中，我们创建了一个容量为 2 的有缓冲通道 ch。我们可以在不阻塞的情况下向通道发送两个值，然后接收并打印这些值。当你希望在发送者和接收者之间解耦，使它们在缓冲区大小的限制内独立工作时，有缓冲通道非常有用。

通道同步

在 Go 中，通道同步是一种通过使用通道来协调和同步 Goroutines（并发线程）执行的技术。通道促进了 Goroutines 之间的安全和有序的通信，使它们能够在特定任务完成或数据准备好时相互发出信号。这种同步机制对于确保 Goroutines 以受控和同步的方式执行至关重要。

以下是一些常见的场景，其中通道同步非常有用：

  1. 等待 Goroutines 完成：你可以使用通道来等待一个或多个 Goroutines 完成它们的任务，然后再继续主程序的执行。
  2. 协调并行任务：通道可以被用来编排多个 Goroutines 同时执行任务，确保它们按照特定的顺序完成工作或在特定点同步。
  3. 收集结果：通道可以用来收集和聚合来自多个 Goroutines 的结果，然后在所有 Goroutines 完成它们的工作后对这些结果进行处理。

让我们通过示例来探索这些场景：

1. 等待 Goroutines 完成

package mainimport ("fmt""sync"
)func worker(id int, wg *sync.WaitGroup) {defer wg.Done()fmt.Printf("Worker %d is working\n", id)
}func main() {var wg sync.WaitGroupfor i := 1; i <= 3; i++ {wg.Add(1)go worker(i, &wg)}wg.Wait() // Wait for all workers to finishfmt.Println("All workers have finished.")
}

在这个示例中，我们有三个工作 Goroutines。我们使用 sync.WaitGroup 来等待它们都完成工作后再打印“所有工作者都已完成”。

2. 协调并行任务

package mainimport ("fmt""sync"
)func main() {var wg sync.WaitGroupch := make(chan int)for i := 1; i <= 3; i++ {wg.Add(1)go func(id int) {defer wg.Done()fmt.Printf("Goroutine %d is working\n", id)ch <- id // Send a signal to the channel when done}(i)}// Wait for all Goroutines to signal completiongo func() {wg.Wait()close(ch) // Close the channel when all Goroutines are done}()for id := range ch {fmt.Printf("Received signal from Goroutine %d\n", id)}fmt.Println("All Goroutines have finished.")
}

在这个示例中，我们有三个 Goroutines 执行工作，并使用一个通道来发出它们完成的信号。我们使用 sync.WaitGroup 来等待所有 Goroutines 完成，而另一个独立的 Goroutine 则监听通道，以知道每个 Goroutine 何时完成其工作。

3. 收集结果

package mainimport ("fmt""sync"
)func worker(id int, resultChan chan<- int, wg *sync.WaitGroup) {defer wg.Done()result := id * 2resultChan <- result // Send the result to the channel
}func main() {var wg sync.WaitGroupresultChan := make(chan int, 3)for i := 1; i <= 3; i++ {wg.Add(1)go worker(i, resultChan, &wg)}wg.Wait() // Wait for all workers to finishclose(resultChan) // Close the channel when all results are sentfor result := range resultChan {fmt.Printf("Received result: %d\n", result)}
}

在这个示例中，三个工作 Goroutines 计算结果并将它们发送到一个通道。主 Goroutine 等待所有工作者完成，关闭通道，然后从通道中读取和处理结果。

这些示例说明了如何使用通道同步在 Go 中的各种并发编程场景中协调和同步 Goroutines。通道为 Goroutines 之间提供了一个强大的机制，使得编写行为可预测和可靠的并发程序变得更加容易。

选择语句：多路复用通道

管理并发任务的关键工具之一是 select 语句。在本文中，我们将探讨 select 语句在多路复用通道中的作用，这是一种使 Go 程序员有效同步和协调 Goroutines 的技术。

使用 select 进行通道的多路复用

当您有多个 Goroutines 通过各种通道进行通信时，您可能需要有效地协调它们的活动。select 语句允许您通过选择可以进行的第一个通道操作来实现这一点。

以下是一个简单的示例，演示了如何使用 select 进行通道的多路复用：

package mainimport ("fmt""time"
)func main() {ch1 := make(chan string)ch2 := make(chan string)go func() {time.Sleep(time.Second)ch1 <- "Message from Channel 1"}()go func() {time.Sleep(time.Millisecond * 500)ch2 <- "Message from Channel 2"}()select {case msg1 := <-ch1:fmt.Println(msg1)case msg2 := <-ch2:fmt.Println(msg2)}fmt.Println("Main function exits")
}

在这个示例中，我们有两个 Goroutines 在两个不同的通道 ch1 和 ch2 上发送消息。select 语句选择第一个变得可用的通道操作，允许我们从 ch1 或 ch2 接收并打印消息。然后程序继续执行主函数，展示了使用 select 进行通道多路复用的强大功能。

使用默认情况下的 select

select 语句还支持一个 default 情况，当您想要处理没有任何通道操作准备好的情况时，这非常有用。以下是一个示例：

package mainimport ("fmt""time"
)func main() {ch := make(chan string)go func() {time.Sleep(time.Second * 2)ch <- "Message from Channel"}()select {case msg := <-ch:fmt.Println(msg)default:fmt.Println("No message received")}fmt.Println("Main function exits")
}

在这种情况下，我们有一个 Goroutine 在通道 ch 上发送消息。然而，select 语句包括一个 default 情况，用于处理在预期时间内没有消息到达的情况。这允许对没有任何通道操作准备好的情况进行优雅的处理。

Go 中的最佳实践和模式：扇出、扇入和关闭通道

当涉及编写干净高效的 Go 代码时，有一些特定的最佳实践和模式可以显著提高您的并发程序的质量和性能。在本文中，我们将探讨两个关键的实践：扇出、扇入 和 关闭通道。这些模式是管理 Go 应用程序中的并发和通信的强大工具。

1. 扇出、扇入

扇出、扇入 模式是一个并发设计模式，它允许您在多个 Goroutines 之间分发工作，然后收集和整合结果。当处理可以并发处理然后聚合的任务时，这种模式尤其有用。

扇出、扇入的示例
package mainimport ("fmt""math/rand""sync""time"
)func worker(id int, input <-chan int, output chan<- int) {for number := range input {// Simulate some worktime.Sleep(time.Millisecond * time.Duration(rand.Intn(100)))output <- number * 2}
}func main() {rand.Seed(time.Now().UnixNano())input := make(chan int)output := make(chan int)const numWorkers = 3var wg sync.WaitGroup// Fan-out: Launch multiple workersfor i := 0; i < numWorkers; i++ {wg.Add(1)go func(id int) {defer wg.Done()worker(id, input, output)}(i)}// Fan-in: Collect resultsgo func() {wg.Wait()close(output)}()// Send data to workersgo func() {for i := 1; i <= 10; i++ {input <- i}close(input)}()// Receive and process resultsfor result := range output {fmt.Println("Result:", result)}
}

在这个示例中，我们创建了三个工作 Goroutines 来执行一些模拟工作，然后将结果发送到一个输出通道。主 Goroutine 生成输入数据，而一个单独的 Goroutine 使用扇入模式收集和处理结果。

2. 关闭通道

关闭通道是一个重要的实践，用于标记数据传输的完成并防止 Goroutines 无限期地阻塞。当您不再计划通过它们发送数据时，关闭通道是至关重要的，以避免死锁。

关闭通道的示例
package mainimport "fmt"func main() {dataChannel := make(chan int, 3)go func() {defer close(dataChannel) // Close the channel when donefor i := 1; i <= 3; i++ {dataChannel <- i}}()// Receive data from the channelfor num := range dataChannel {fmt.Println("Received:", num)}
}

在这个示例中，我们创建了一个容量为3的带缓冲通道dataChannel。在向该通道发送三个值之后，我们使用close函数关闭它。关闭通道向任何接收者发出信号，表示不会再发送更多的数据。这使得接收的 Goroutine 在所有数据都已被处理完毕后可以优雅地退出。


http://www.ppmy.cn/news/1278540.html

相关文章

速盾网络：网站用速盾cdn的好处

速盾网络：网站用速盾cdn的好处

随着互联网的快速发展&#xff0c;网站的速度和稳定性成为了用户访问体验的关键因素。为了提高网站的性能和可用性&#xff0c;许多网站开始使用CDN&#xff08;Content Delivery Network&#xff09;服务。本文将介绍CDN的基本概念、工作原理以及使用CDN的好处。一、CDN的基本…
阅读更多...
Ubuntu 常用命令之 df 命令用法介绍

Ubuntu 常用命令之 df 命令用法介绍

&#x1f4d1;Linux/Ubuntu 常用命令归类整理 在Ubuntu系统下&#xff0c;df命令是用来查看文件系统的磁盘空间占用情况的。df是disk free的缩写&#xff0c;这个命令可以获取硬盘被占用了多少空间&#xff0c;还有多少空间是可用的&#xff0c;硬盘的挂载点等信息。 df命令的…
阅读更多...
多级队列调度算法-第二十三天

多级队列调度算法-第二十三天

~看一个图就能明白~ ~over~
阅读更多...
【重点】【DP】322.零钱兑换

【重点】【DP】322.零钱兑换

题目 法1&#xff1a;动态规划 // 时间复杂度&#xff1a;O(kN) class Solution {public int coinChange(int[] coins, int amount) {int[] dp new int[amount 1];Arrays.fill(dp, amount 1);dp[0] 0;for (int i 1; i < dp.length; i) {for (int coin : coins) {if (…
阅读更多...
export default

export default

export default 是 ES6 模块系统中的语法 用于将一个值、变量、函数或类作为模块的默认导出 默认导出在一个模块中只能有一个&#xff0c;而且不需要使用花括号 { } 进行包裹 下面是 export default 的用法和一些示例&#xff1a; 1.导出一个值或变量作为默认导出 // modu…
阅读更多...
Valentina Studio Pro for Mac：高效数据库管理工具

Valentina Studio Pro for Mac：高效数据库管理工具

作为一款强大而高效的数据库管理工具&#xff0c;Valentina Studio Pro for Mac在Mac平台上的表现无疑是令人印象深刻的。无论您是初学者还是专业数据库管理员&#xff0c;Valentina Studio Pro都能够满足您的需要&#xff0c;并提供一流的工具和功能来简化数据库管理的过程。 …
阅读更多...
Sui 生态排名第一的头部流动性协议 NAVI Protocol 活动进行中

Sui 生态排名第一的头部流动性协议 NAVI Protocol 活动进行中

作为在熊市中启动的新生公链&#xff0c;Sui 正在稳步崛起。公链的 TVL 持续攀升&#xff0c;目前已经达到了 1.76亿美元&#xff0c;闯入了公链排名前20榜单。仅过去四个月内&#xff0c;TVL 增加了10倍&#xff0c;并且增长仍在继续&#xff0c;SUI 的价格在近期也有了很亮眼…
阅读更多...
解决xcode 运行不老iPhone 15 iOS 17.1 设备的问题

解决xcode 运行不老iPhone 15 iOS 17.1 设备的问题

问题 最近要查看一下ios 17.1的设备的性能&#xff0c;但是当前版本的Xcode运行不了 解决方法 1、更新Xcode版本到15.1以上 2、更新完成后&#xff0c;大概率出现这个情况 原因&#xff1a;在app Store中更新到Xcode15后,运行不了模拟器和真机.需要下载iOS 17对应的模拟器.&…
阅读更多...
最新文章

Copyright @ 2022~2023