Golang在CentOS上的多线程编程实践

在CentOS上使用Golang进行多线程编程，主要涉及到Go语言的并发模型，即goroutines和channels。以下是一些基本的实践步骤和示例代码：

1. 安装Go环境

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

sudo yum install golang

2. 创建一个简单的Go程序

创建一个新的Go文件，例如main.go，并编写一个简单的多线程程序。

package main

import (
	"fmt"
	"sync"
)

func worker(id int, wg *sync.WaitGroup) {
    
	defer wg.Done()
	fmt.Printf("Worker %d starting\n", id)
	// 模拟一些工作
	for i := 0;
     i <
     5;
 i++ {

		fmt.Printf("Worker %d working... %d\n", id, i)
	}

	fmt.Printf("Worker %d done\n", id)
}


func main() {
    
	var wg sync.WaitGroup

	// 启动多个goroutine
	for i := 1;
     i <
    = 3;
 i++ {
    
		wg.Add(1)
		go worker(i, &
wg)
	}


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

3. 运行程序

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

go run main.go

4. 解释代码

• goroutines: go worker(i, & wg) 启动一个新的goroutine来执行worker函数。
• sync.WaitGroup: sync.WaitGroup用于等待一组goroutine完成。wg.Add(1)增加计数器，wg.Done()减少计数器，wg.Wait()阻塞直到计数器为0。

5. 使用Channels进行通信

Channels是Go语言中用于goroutines之间通信和同步的原语。以下是一个使用channels的示例：

package main

import (
	"fmt"
)

func worker(id int, ch chan string) {

	fmt.Printf("Worker %d starting\n", id)
	for n := range ch {

		fmt.Printf("Worker %d received: %s\n", id, n)
	}

	fmt.Printf("Worker %d done\n", id)
}


func main() {
    
	ch := make(chan string)

	for i := 1;
     i <
    = 3;
 i++ {

		go worker(i, ch)
	}
    

	for i := 1;
     i <
    = 5;
 i++ {
    
		ch <
- fmt.Sprintf("Message %d", i)
	}


	close(ch)
}
    

6. 运行程序

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

go run main.go

7. 解释代码

• Channels: ch := make(chan string) 创建一个字符串类型的channel。ch < - fmt.Sprintf("Message %d", i) 向channel发送消息，for n := range ch 从channel接收消息。

通过这些步骤，你可以在CentOS上使用Golang进行多线程编程。Go语言的并发模型非常强大且易于使用，适合处理高并发场景。

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！