在Go语言中，并发的实现主要依靠goroutine和channel。goroutine类似于线程，但并非线程，goroutine是由Go的运行时直接管理的。channel是一种内建的数据结构，用于协程之间的同步和通信。
- 创建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执行完成
}- 使用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
}
}
}- 使用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来实现并发编程。