CentOS中Golang并发编程如何实现 - 问答

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

安装Golang：如果你还没有安装Golang，可以通过以下命令安装：
```
sudo yum install golang
```

编写并发程序：使用Go语言的go关键字来启动一个新的goroutine。goroutines是轻量级的线程，由Go运行时管理。

package main

import (
    "fmt"
    "time"
)

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

func main() {
    go printNumbers() // 启动一个新的goroutine

    // 主goroutine继续执行
    for i := 1; i <= 5; i++ {
        fmt.Printf("Main: %d\n", i)
        time.Sleep(time.Second)
    }
}

使用通道进行通信：通道是Go语言中用于在goroutines之间传递数据的机制。你可以使用make(chan Type)来创建一个通道，并使用<-操作符来发送和接收数据。

package main

import (
    "fmt"
)

func sum(s []int, c chan int) {
    sum := 0
    for _, v := range s {
        sum += v
    }
    c <- sum // 将结果发送到通道c
    close(c) // 关闭通道
}

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

    c := make(chan int)
    go sum(s[:len(s)/2], c)
    go sum(s[len(s)/2:], c)

    x, y := <-c, <-c // 从通道中接收数据

    fmt.Println(x, y, x+y)
}

同步goroutines：使用sync.WaitGroup来等待一组goroutines完成。

package main

import (
    "fmt"
    "sync"
)

func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done() // 在函数结束时调用Done()来通知WaitGroup一个goroutine已经完成

    fmt.Printf("Worker %d starting\n", id)
    // 模拟工作
    fmt.Printf("Worker %d done\n", id)
}

func main() {
    var wg sync.WaitGroup

    for i := 1; i <= 5; i++ {
        wg.Add(1) // 增加WaitGroup的计数器
        go worker(i, &wg)
    }

    wg.Wait() // 等待所有goroutines完成
    fmt.Println("All workers done")
}

运行并发程序：编译并运行你的Go程序：
```
go build your_program.go
./your_program
```

通过以上步骤，你可以在CentOS系统中使用Golang实现并发编程。Go语言的并发模型简单而强大，适合处理高并发场景。

0 赞

0 踩