Goroutine
Goroutine 是 Go 语言中的一种并发机制,它是一种轻量级线程,可以通过关键字 go 启动一个新的 Goroutine。相比传统的线程,Goroutine 拥有更小的栈空间,因此可以创建更多的 Goroutine。
下面是一个简单的 Goroutine 的示例:
package main
import (
"fmt"
"time"
)
func main() {
go func() {
for i := 0; i < 5; i++ {
fmt.Println("Goroutine:", i)
time.Sleep(time.Second)
}
}()
for i := 0; i < 5; i++ {
fmt.Println("Main:", i)
time.Sleep(time.Second)
}
}
在上面的示例中,我们使用 go 关键字创建了一个匿名函数的 Goroutine。在 main 函数中,我们启动了一个 Goroutine,它会输出 Goroutine 和数字 i,然后等待一秒钟。同时,main 函数也会输出 Main 和数字 i,然后等待一秒钟。通过这个示例,我们可以看到,Goroutine 和 main 函数是并发执行的。
go function()
其中 function() 表示要在 goroutine 中执行的函数。在这种写法中,go 关键字后面直接跟着一个函数调用,并在函数调用后面添加了一对空的圆括号。这是因为在 Go 语言中,如果要将一个函数作为 goroutine 来运行,需要将它包装成一个函数值。而在这种写法中,函数值的声明和调用是同时完成的。另外,这种写法还可以在函数调用后面直接添加参数,例如:
go
Copy code
go func(x int, y int) {
// goroutine body
}(1, 2)
Channel
Channel 是 Go 语言中的一种通信机制,可以用来在 Goroutine 之间传递数据。Channel 可以看作是一个管道,数据可以从一个 Goroutine 通过 Channel 传递到另一个 Goroutine。
下面是一个简单的 Channel 的示例:
package main
import (
"fmt"
"time"
)
func worker(id int, jobs <-chan int, results chan<- int) {
for j := range jobs {
fmt.Printf("Worker %d started job %d\n", id, j)
time.Sleep(time.Second)
fmt.Printf("Worker %d finished job %d\n", id, j)
results <- j * 2
}
}
func main() {
jobs := make(chan int, 100) //这行代码是在创建一个容量为100的整数类型的通道(channel)并将其赋值给变量jobs。这个通道可以在不同的goroutine之间传递整数类型的数据,而容量为100则表示这个通道最多可以同时存储100个整数,当通道中的元素数量达到容量上限时,再往里面发送数据会被阻塞,直到通道中有元素被接收走为止。
results := make(chan int, 100)
for w := 1; w <= 3; w++ {
go worker(w, jobs, results)
}
for j := 1; j <= 5; j++ {
jobs <- j
}
close(jobs)
for a := 1; a <= 5; a++ {
<-results
}
}
在上面的示例中,我们定义了一个 worker 函数,它从 jobs Channel 中读取任务,然后执行任务并将结果发送到 results Channel 中。在 main 函数中,我们启动了 3 个 Goroutine,它们会执行 worker 函数。然后,我们向 jobs Channel 中发送了 5 个任务。最后,我们从 results Channel 中读取了 5 个结果。
通过这个示例,我们可以看到,Channel 可以很方便地在 Goroutine 之间传递数据,从而实现并发编程。
chan<- int 是一个只写的通道类型,表示只能向通道中写入数据,而不能从中读取数据。这种类型的通道常用于只提供数据发送的场合,如生产者-消费者模型中的生产者,它们只需要往通道中发送数据即可。
chan<- int 是一个只写的通道类型,表示只能向通道中写入数据,而不能从中读取数据。这种类型的通道常用于只提供数据发送的场合,如生产者-消费者模型中的生产者,它们只需要往通道中发送数据即可。