【Go】进程、线程、协程

在Go语言中，并发的实现主要依靠goroutine和channel。goroutine类似于线程，但并非线程，goroutine是由Go的运行时直接管理的。channel是一种内建的数据结构，用于协程之间的同步和通信。

1. 创建goroutine

Go语言中创建goroutine的方式很简单，只需要在调用函数时使用关键字go即可。

package main
 
import (
    "fmt"
    "time"
)
 
func hello() {
    fmt.Println("Hello world goroutine")
}
 
func main() {
    go hello() // 创建一个goroutine
    fmt.Println("main function done")
    time.Sleep(1 * time.Second) // 等待goroutine执行完成
}

2. 使用channel同步goroutine

package main
 
import (
    "fmt"
    "time"
)
 
func printNum(c chan int, end chan bool) {
    for i := 0; i < 5; i++ {
        c <- i
    }
    end <- true
}
 
func main() {
    c := make(chan int)
    end := make(chan bool)
 
    go printNum(c, end)
 
    for {
        select {
        case num := <-c:
            fmt.Println(num)
        case <-end:
            fmt.Println("End of program")
            return
        }
    }
}

3. 使用goroutine和channel实现生产者-消费者模型

package main
 
import (
    "fmt"
    "sync"
    "time"
)
 
var (
    buffer = make(chan int, 10)
    wg     sync.WaitGroup
)
 
func producer(i int) {
    defer wg.Done()
    for j := 0; j < 5; j++ {
        buffer <- (i * 10) + j
        fmt.Printf("Produced: %d\n", (i*10)+j)
    }
}
 
func consumer() {
    defer wg.Done()
    for {
        num := <-buffer
        fmt.Printf("Consumed: %d\n", num)
        time.Sleep(1 * time.Second)
    }
}
 
func main() {
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go producer(i)
    }
 
    wg.Add(1)
    go consumer()
 
    wg.Wait()
}

以上代码展示了如何在Go语言中使用goroutine和channel来实现并发编程。