温馨提示×

golang怎么开多个线程

小亿
130
2023-10-22 11:27:33
栏目: 编程语言

在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来实现多线程的并发执行。

0