golang怎么开多个线程

avatar
作者
筋斗云
阅读量:1

在Go语言中,可以使用goroutine来实现多线程的并发执行。goroutine是Go语言中轻量级的线程,可以在一个程序中创建很多个goroutine,并且它们之间的切换和调度是由Go语言的运行时自动完成的。

要创建一个新的goroutine,只需要在函数或方法调用前加上关键字go即可。例如:

package main  import (     "fmt"     "time" )  func main() {     // 创建一个新的goroutine     go printNumbers()      // 主goroutine继续执行其他任务     for i := 0; i < 5; i++ {         fmt.Println("Main goroutine:", i)         time.Sleep(time.Second)     } }  func printNumbers() {     for i := 0; i < 5; i++ {         fmt.Println("New goroutine:", i)         time.Sleep(time.Second)     } } 

在上面的例子中,我们使用go printNumbers()创建了一个新的goroutine来执行printNumbers函数。主goroutine继续执行for循环中的任务,而新的goroutine会并发地执行printNumbers函数中的任务。

需要注意的是,主goroutine在结束之前不会等待其他goroutine的完成,所以在上面的例子中,主goroutine和新的goroutine会并发地执行,打印出来的数字是交替出现的。

此外,还可以使用sync.WaitGroup来等待所有的goroutine都执行完毕。例如:

package main  import (     "fmt"     "sync"     "time" )  func main() {     var wg sync.WaitGroup      // 创建两个新的goroutine     wg.Add(2)     go printNumbers(&wg)     go printLetters(&wg)      // 等待所有的goroutine执行完毕     wg.Wait() }  func printNumbers(wg *sync.WaitGroup) {     defer wg.Done()      for i := 0; i < 5; i++ {         fmt.Println("Numbers:", i)         time.Sleep(time.Second)     } }  func printLetters(wg *sync.WaitGroup) {     defer wg.Done()      for i := 'A'; i < 'E'; i++ {         fmt.Println("Letters:", string(i))         time.Sleep(time.Second)     } } 

在上面的例子中,我们使用sync.WaitGroup来等待所有的goroutine执行完毕。首先在main函数中创建了一个WaitGroup实例,并且调用了Add方法来指定需要等待的goroutine的数量。然后在每个goroutine的函数中,都调用了wg.Done()来表示当前goroutine执行完毕。最后,在main函数中调用wg.Wait()来等待所有的goroutine完成。

通过以上两种方式,就可以在Go语言中开启多个goroutine来实现多线程的并发执行。

广告一刻

为您即时展示最新活动产品广告消息,让您随时掌握产品活动新动态!