golang并发模型怎么使用

Golang的并发模型是通过goroutine和channel来实现的。

1. Goroutine: Goroutine是轻量级的线程，可以同时执行多个goroutine。可以使用关键字go来启动一个goroutine，例如：

go func() {
// 并发执行的代码
}()

2. Channel: Channel是goroutine之间进行通信的机制，可以用于传递数据和同步goroutine的执行。可以使用make函数创建一个channel，例如：

ch := make(chan 数据类型)

发送和接收数据可以使用<-运算符，例如：

ch <- 数据 // 发送数据到channel
数据 = <-ch // 从channel接收数据

以下是一个使用goroutine和channel实现并发模型的示例代码：

package main
import (
"fmt"
"time"
)
func worker(id int, jobs <-chan int, results chan<- int) {
for j := range jobs {
fmt.Println("worker", id, "processing job", j)
time.Sleep(time.Second) // 模拟耗时操作
results <- j * 2
}
}
func main() {
numJobs := 5
jobs := make(chan int, numJobs)
results := make(chan int, numJobs)
// 启动3个goroutine来处理任务
for i := 1; i <= 3; i++ {
go worker(i, jobs, results)
}
// 发送任务到jobs channel
for j := 1; j <= numJobs; j++ {
jobs <- j
}
close(jobs)
// 从results channel接收结果
for r := 1; r <= numJobs; r++ {
fmt.Println(<-results)
}
}

在上面的示例中，主函数创建了两个channel，一个用来传递任务（jobs），一个用来传递结果（results）。

然后，主函数启动了三个goroutine来处理任务，每个goroutine会从jobs channel中接收任务，并将处理结果发送到results channel中。

最后，主函数从results channel中接收结果并打印出来。

这个示例展示了一个简单的并发模型，其中多个goroutine并行执行任务，并通过channel进行通信和同步。