Go并发编程入门

本文由 ChatMoney团队出品

Go 并发编程：Goroutines 与 Channels

并发编程是 Go 语言的一个重要特点，它高效地利用现代硬件的多核和并行性来提升应用性能。本文将简介 Go 并发编程的基本概念，包括 Goroutines 和 Channels。

Goroutines

Goroutines 是 Go 并发编程的基本单位，它们是轻量级线程，由 Go 运行时管理。创建一个 goroutine 非常简单，只需在函数调用前添加 go 关键字即可

例如：

package main

import (
    "fmt"
    "time"
)

func say(s string) {
    for i := 0; i < 5; i++ {
        time.Sleep(100 * time.Millisecond)
        fmt.Println(s)
    }
}

func main() {
    go say("world")
    say("hello")
}

输出：
world
hello
hello
world
world
hello
hello
world
world
hello

在这个例子中，say("world") 在一个 goroutine 中并发执行，而 say("hello") 在主 goroutine 中执行。

Channels

Channels 是 Go 提供的一种在 goroutines 之间通信的方式。使用 make 函数创建一个 channel：

ch := make(chan int)

可以通过 <- 操作符发送和接收数据：

ch <- 42  // 发送数据到 channel
value := <- ch  // 从 channel 接收数据

结合使用 Goroutines 和 Channels，可以创建高效的并发程序。

package main

import "fmt"

func sum(s []int, c chan int) {
    sum := 0
    for _, v := range s {
       sum += v
    }
    c <- sum // 把 sum 发送到 channel c
    close(c) // 关闭通道，表示不再发送数据
}

func main() {
    s := []int{7, 2, 8, -9, 4, 0}

    c1 := make(chan int)
    c2 := make(chan int)
    
    go sum(s[:len(s)/2], c1)
    go sum(s[len(s)/2:], c2)
    
    x := <-c1 // 从 c1 中接收
    y := <-c2 // 从 c2 中接收
    
    fmt.Println(x, y, x+y)
}

输出
17 -5 12

在这个程序中，我们使用两个 goroutine 计算数组的部分和，然后通过 channel 返回结果。

最后

掌握这些基础知识，有助于你在实际开发中更有效地利用 Go 的并发特性，提升程序的性能和响应速度。

关于我们

本文由ChatMoney团队出品，ChatMoney专注于AI应用落地与变现，我们提供全套、持续更新的AI源码系统与可执行的变现方案，致力于帮助更多人利用AI来变现，欢迎进入ChatMoney获取更多AI变现方案！