golang并发模型怎么使用

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

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

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

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

ch := make(chan 数据类型)

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

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

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

package mainimport ("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 := 5jobs := make(chan int, numJobs)results := make(chan int, numJobs)// 启动3个goroutine来处理任务for i := 1; i <= 3; i++ {go worker(i, jobs, results)}// 发送任务到jobs channelfor 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进行通信和同步。