Linux平台上Golang如何进行并发控制

在Linux平台上使用Golang进行并发控制，主要依赖于Go语言的并发原语，如goroutines、channels和sync包。以下是一些常用的并发控制方法：

1. Goroutines：Goroutines是Go语言中实现并发的基本单位。它们是轻量级的线程，可以在一个程序中同时运行多个goroutines。要创建一个新的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()
	time.Sleep(6 * time.Second)
}

2. Channels：Channels是Go语言中用于在goroutines之间传递数据的通道。它们可以确保数据在多个goroutines之间安全地共享。要创建一个channel，可以使用make函数。

package main

import (
	"fmt"
	"time"
)

func printNumbers(numbers chan int) {
	for num := range numbers {
		fmt.Printf("Number: %d\n", num)
		time.Sleep(1 * time.Second)
	}
}

func main() {
	numbers := make(chan int, 5)
	go printNumbers(numbers)

	for i := 1; i <= 5; i++ {
		numbers <- i
	}

	close(numbers)
	time.Sleep(6 * time.Second)
}

3. Sync包：Sync包提供了一些用于同步goroutines的工具，如WaitGroup、Mutex和Cond等。

• WaitGroup：WaitGroup用于等待一组goroutines完成。它提供了Add、Done和Wait方法。

package main

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

func printNumbers(wg *sync.WaitGroup) {
	defer wg.Done()

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

func main() {
	var wg sync.WaitGroup
	wg.Add(1)

	go printNumbers(&wg)
	wg.Wait()
}

• Mutex：Mutex用于保护共享资源，确保同一时间只有一个goroutine可以访问该资源。

package main

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

var counter int
var mutex sync.Mutex

func incrementCounter() {
	mutex.Lock()
	defer mutex.Unlock()

	counter++
	fmt.Printf("Counter: %d\n", counter)
	time.Sleep(1 * time.Second)
}

func main() {
	wg := sync.WaitGroup{}

	for i := 0; i < 5; i++ {
		wg.Add(1)
		go incrementCounter()
		wg.Wait()
	}
}

这些是Golang在Linux平台上进行并发控制的一些基本方法。根据实际需求，可以组合使用这些方法来实现更复杂的并发控制。