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实现并发模型的示例代码:
```go
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进行通信和同步。