通过结合 goroutine 和 channel，go 语言中的并发编程可以构建高效的应用程序。goroutine 是轻量级线程，可通过 go 关键字创建。channel 是数据交换管道，可通过 make 函数创建。goroutine 可以向 channel 发送数据，而其他 goroutine 可以从 channel 接收数据。此技术可用于各种并发方案，例如并行字符串搜索。在并行字符串搜索的示例中，多个 goroutine 并发搜索字符串数组，并在找到匹配项时通过 channel 将索引发送回主 goroutine。
Go 语言函数：利用 goroutine 和 channel 的强强联手
Go 语言中，goroutine 和 channel 的结合是并发编程的基础。goroutine 允许我们开启多个并发轻量级线程，而 channel 则作为沟通和数据交换的管道。将这两个特性结合起来，我们可以构建高效、可伸缩的并发应用程序。
goroutine
立即学习“go语言免费学习笔记（深入）”；
goroutine 是 Go 语言中的轻量级并发库。使用 go 关键字可以轻松地创建一个 goroutine：
go func() {
// 并发执行的代码
}channel
channel 是 Go 语言中实现并发数据交换的管道。它允许 goroutine 之间安全地发送和接收数据。我们可以使用 make 函数来创建一个 channel：
ch := make(chan int)
使用 goroutine 和 channel
goroutine 和 channel 的联用非常简单。一个 goroutine 可以向 channel 发送数据，而另一个 goroutine 可以从 channel 中接收数据：
func producer(ch chan<- int) {
for i := 0; i < 10; i++ {
ch <- i
}
close(ch)
}
func consumer(ch <-chan int) {
for v := range ch {
fmt.Println(v)
}
}
func main() {
ch := make(chan int)
go producer(ch)
consumer(ch)
}实战案例
我们使用 goroutine 和 channel 来构建一个并发的字符串搜索应用程序。应用程序使用多个 goroutine 并发搜索字符串数组中的指定子字符串。
import (
"fmt"
"sync"
)
func search(str string, arr []string) (int, bool) {
for i, s := range arr {
if s == str {
return i, true
}
}
return -1, false
}
func main() {
arr := []string{"a", "b", "c", "d", "e", "f"}
ch := make(chan int, len(arr))
var wg sync.WaitGroup
wg.Add(len(arr))
for i, str := range arr {
go func(i int, str string) {
defer wg.Done()
idx, found := search(str, arr)
if found {
ch <- idx
}
}(i, str)
}
wg.Wait()
close(ch)
for v := range ch {
fmt.Println(v)
}
}这个应用程序启动多个 goroutine 并发搜索字符串数组中的指定字符串。每个 goroutine 将在找到匹配项时将索引发送到 channel 中。主 goroutine 从 channel 中接收索引，并打印匹配项的位置。
