CentOS上Golang如何实现并发编程

在CentOS上使用Golang实现并发编程，主要依赖于Go语言的轻量级线程——goroutines和通道（channels）。以下是实现并发编程的基本步骤：

1. 安装Go环境： 确保你的CentOS系统上已经安装了Go。如果没有安装，可以通过以下命令安装：

   sudo yum install golang
   

2. 创建Go程序： 创建一个新的Go文件，例如main.go。

3. 定义goroutines： 使用go关键字启动一个goroutine。goroutine是Go语言中实现并发的主要方式。

   package main
   
   import (
       "fmt"
       "time"
   )
   
   func printNumbers() {
       for i := 1; i <= 5; i++ {
           fmt.Printf("Number: %d\n", i)
           time.Sleep(1 * time.Second)
       }
   }
   
   func main() {
       go printNumbers() // 启动一个新的goroutine
   
       // 主goroutine继续执行其他任务
       for i := 1; i <= 5; i++ {
           fmt.Printf("Main: %d\n", i)
           time.Sleep(1 * time.Second)
       }
   }
   

4. 使用通道进行通信： 通道是goroutines之间进行通信和同步的主要方式。你可以使用make(chan int)创建一个通道，并通过<-操作符发送和接收数据。

   package main
   
   import (
       "fmt"
       "time"
   )
   
   func worker(done chan bool) {
       fmt.Println("Worker started")
       time.Sleep(time.Second)
       fmt.Println("Worker finished")
       done <- true
   }
   
   func main() {
       done := make(chan bool)
   
       go worker(done)
   
       <-done // 等待worker完成
       fmt.Println("Main function finished")
   }
   

5. 同步goroutines： 除了使用通道，你还可以使用sync.WaitGroup来同步多个goroutines。

   package main
   
   import (
       "fmt"
       "sync"
       "time"
   )
   
   func worker(id int, wg *sync.WaitGroup) {
       defer wg.Done()
       fmt.Printf("Worker %d started\n", id)
       time.Sleep(time.Second)
       fmt.Printf("Worker %d finished\n", id)
   }
   
   func main() {
       var wg sync.WaitGroup
   
       for i := 1; i <= 5; i++ {
           wg.Add(1)
           go worker(i, &wg)
       }
   
       wg.Wait() // 等待所有goroutines完成
       fmt.Println("All workers finished")
   }
   

6. 运行程序： 在终端中运行你的Go程序：

   go run main.go
   

通过以上步骤，你可以在CentOS上使用Golang实现并发编程。Golang的并发模型非常强大且易于使用，适合处理各种并发任务。