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平臺上進行并發控制的一些基本方法。根據實際需求，可以組合使用這些方法來實現更復雜的并發控制。