CentOS下Golang并发编程实战指南

在CentOS下用Golang搞并发编程，其实核心就两个东西：goroutines（轻量级线程）和channels（通道）。这俩是Go语言在设计上最出彩的地方，简单直接，但用好了效率极高。下面咱们就掰开揉碎了聊聊。

Goroutines：开一个“协程”就像调用一个函数

Goroutines是Go实现并发的基石。它们到底有多轻量？一个进程里跑几千个goroutines是家常便饭，系统开销远小于操作系统线程。创建方法更是简单——在函数调用前加个 go 关键字就行。比如这段代码，让 printNumbers 函数在后台并发执行：

package main

import (
    "fmt"
    "time"
)

func printNumbers() {
    for i := 1; i <= 5; i++ {
        time.Sleep(1 * time.Second)
        fmt.Printf("Number: %d\n", i)
    }
}

func main() {
    go printNumbers()
    time.Sleep(6 * time.Second)
}

注意，主函数里用 time.Sleep(6 * time.Second) 是为了等待goroutine执行完，否则主协程一退出，所有goroutine都会终止。实际项目中肯定不能这么干，后面会用到更优雅的同步方式。

Channels：让goroutines之间安全地“传纸条”

Channels是Go语言里goroutines之间通信的管道。它天然带同步机制——往channel里写数据，如果没人读，写操作会阻塞；同样，读操作也会等待数据到来。这就避免了显式加锁的麻烦。来看一个典型的生产者-消费者模式：

package main

import (
    "fmt"
    "time"
)

func produce(numbers chan<- int) {
    for i := 1; i <= 5; i++ {
        time.Sleep(1 * time.Second)
        numbers <- i
    }
    close(numbers)
}

func consume(numbers <-chan int) {
    for num := range numbers {
        fmt.Printf("Received number: %d\n", num)
    }
}

func main() {
    numbers := make(chan int)
    go produce(numbers)
    consume(numbers)
    time.Sleep(6 * time.Second)
}

这里 produce 只往channel里写，consume 只从channel里读。通过 close(numbers) 告诉消费者数据发送完毕，消费者用 range 循环读取直到channel关闭。整个流程清晰、安全，而且不用任何锁。

同步：当多个goroutine竞争同一份资源时

虽然channel能解决大部分通信问题，但有些场景还是需要传统同步原语——比如多个goroutine同时修改同一个变量。Go标准库提供了 sync.Mutex、sync.WaitGroup、sync.Once 等工具。下面这个例子展示了如何用 sync.Mutex 保护一个计数器，并用 sync.WaitGroup 等待所有goroutine完成：

package main

import (
    "fmt"
    "sync"
    "time"
)

var counter int
var mutex sync.Mutex

func increment(wg *sync.WaitGroup) {
    mutex.Lock()
    defer mutex.Unlock()
    counter++
    wg.Done()
}

func main() {
    var wg sync.WaitGroup
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go increment(&wg)
    }
    wg.Wait()
    fmt.Printf("Counter: %d\n", counter)
    time.Sleep(1 * time.Second)
}

这里的关键点：mutex.Lock() 和 defer mutex.Unlock() 确保同一时刻只有一个goroutine能修改 counter；wg.Add(1) 和 wg.Done() 配合 wg.Wait() 则优雅地等待所有increment任务结束。相比之下，比直接 time.Sleep 靠谱得多。

在CentOS上跑起来

CentOS下安装Go很简单：去官网下载Linux版本的安装包，解压后配置好 PATH 环境变量，然后 go run 你的程序.go 就能直接运行。编译成二进制文件用 go build，部署起来也很方便。

说到底，Golang的并发模型就是“goroutines + channels”这套组合拳。把goroutine当作轻量级任务，用channel解决通信和同步，再辅以必要的互斥锁，在CentOS上写出高效、安全的并发程序并不难。关键是要理解“不要通过共享内存来通信，而要通过通信来共享内存”这个设计哲学。