Linux中Golang如何实现并发控制

在 Linux 系统中，使用 Golang 实现并发控制可以通过以下几种方式：

1. Goroutines：Golang 的轻量级线程，可以轻松创建成千上万个。通过 go 关键字启动一个新的 Goroutine。

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：用于在 Goroutines 之间传递数据。可以将其视为一种同步机制，以确保 Goroutines 按照预期的顺序执行。

package main

import (
 "fmt"
 "time"
)

func printNumbers(c chan int) {
 for i := 1; i <= 5; i++ {
  c <- i
  time.Sleep(1 * time.Second)
 }
 close(c)
}

func main() {
 c := make(chan int)
 go printNumbers(c)

 for num := range c {
  fmt.Printf("Number: %d\n", num)
 }
}

3. Mutexes：互斥锁，用于确保在同一时间只有一个 Goroutine 访问共享资源。

package main

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

var counter int
var mutex sync.Mutex

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

 counter++
 time.Sleep(1 * time.Second)
}

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

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

 wg.Wait()
 fmt.Printf("Counter: %d\n", counter)
}

4. Select：用于在多个通道操作中进行选择。可以将其视为一种同步机制，以确保 Goroutines 按照预期的顺序执行。

package main

import (
 "fmt"
 "time"
)

func printNumbers(c chan int) {
 for i := 1; i <= 5; i++ {
  c <- i
  time.Sleep(1 * time.Second)
 }
 close(c)
}

func main() {
 c1 := make(chan int)
 c2 := make(chan int)

 go printNumbers(c1)
 go printNumbers(c2)

 for i := 0; i < 10; i++ {
  select {
  case num := <-c1:
   fmt.Printf("Number from c1: %d\n", num)
  case num := <-c2:
   fmt.Printf("Number from c2: %d\n", num)
  }
 }
}

这些方法可以帮助你在 Linux 系统中使用 Golang 实现并发控制。根据你的需求，可以选择合适的方法来确保 Goroutines 之间的同步和数据传递。