CentOS下Golang如何实现并发控制 - 问答

在 CentOS 下使用 Golang 实现并发控制，主要依赖于 Go 语言的 goroutine 和 channel 特性。goroutine 是轻量级的线程，可以让你轻松地创建成千上万个并发任务。channel 则是用于在 goroutine 之间传递数据和同步操作。

以下是一个简单的示例，展示了如何在 CentOS 下使用 Golang 实现并发控制：

首先，确保你已经安装了 Golang。如果没有，请访问 Golang 官网（https://golang.org/dl/）下载并安装。
创建一个名为 main.go 的文件，并输入以下代码：

package main

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

func worker(id int, wg *sync.WaitGroup) {
	defer wg.Done()

	fmt.Printf("Worker %d starting\n", id)
	time.Sleep(time.Second)
	fmt.Printf("Worker %d done\n", id)
}

func main() {
	var wg sync.WaitGroup

	for i := 1; i <= 5; i++ {
		wg.Add(1)
		go worker(i, &wg)
	}

	wg.Wait()
	fmt.Println("All workers done")
}

在这个示例中，我们创建了一个名为 worker 的函数，它接受一个整数 ID 和一个指向 sync.WaitGroup 的指针。worker 函数会模拟一个耗时任务（通过 time.Sleep），然后输出完成信息。

在 main 函数中，我们使用 sync.WaitGroup 来等待所有 goroutine 完成。我们创建了 5 个 goroutine，并为每个 goroutine 调用 wg.Add(1) 来表示有一个新的任务需要等待。然后，我们调用 wg.Wait() 来阻塞主线程，直到所有 goroutine 完成。

在终端中，导航到包含 main.go 文件的目录，并运行以下命令来编译并运行程序：

go build main.go
./main

观察输出结果，你会看到所有 worker 都在并发地执行任务，并在完成后输出相应的信息。

这个示例展示了如何在 CentOS 下使用 Golang 实现基本的并发控制。你可以根据实际需求调整代码，例如使用 channel 来传递数据或实现更复杂的同步操作。

0 赞

0 踩