golang 创建线程

在Golang语言中，创建线程是一项常见的任务。Golang为我们提供了一个简单而强大的并发模型，其中包括了创建和管理线程的功能。通过使用Goroutine和Channel，我们可以轻松地实现并发编程，从而充分利用多核处理器的能力。

使用goroutine创建线程

在Golang中，我们可以使用goroutine来创建线程。goroutine是一种轻量级的执行单元，可以在Go语言的运行时被调度和管理。与传统的线程相比，goroutine的创建和销毁过程非常快速，这使得我们可以方便地创建大量的并发任务。

要创建一个goroutine，我们只需要在函数调用前加上"go"关键字即可。这会告诉Go运行时启动一个新的goroutine，并在后台执行函数。例如：

func worker() {
    // 执行一些工作
}

func main() {
    go worker()  // 创建并发执行的goroutine
    // 执行其他任务
}

在这个例子中，我们在main函数中创建了一个goroutine来执行worker函数。worker函数会在后台并发执行，而main函数会继续执行其他任务。这样，我们就实现了并发执行的效果。

使用channel进行通信

使用goroutine创建线程只是一部分，线程之间的通信也是非常重要的。在Golang中，我们可以使用channel来进行协程之间的通信。channel是一种特殊的数据类型，可以用来传递和同步数据。

要创建一个channel，我们需要使用内置的make函数。例如：

ch := make(chan int)  // 创建一个用于传递整数的channel

通过channel，我们可以将数据从一个goroutine发送到另一个goroutine。发送数据使用"<-"操作符，接收数据使用"="操作符。例如：

func worker(ch chan int) {
    ch <- 42  // 将42发送到channel
}

func main() {
    ch := make(chan int)
    go worker(ch)  // 创建并发执行的goroutine
    result := <-ch  // 从channel接收数据
    fmt.Println(result)  // 输出42
}

在这个例子中，worker函数将整数42发送到了channel ch中。在main函数中，我们从channel ch中接收数据，并将结果赋值给result变量。最后，我们打印出result的值，应该是42。

控制goroutine的数量

如果我们创建了太多的goroutine，可能会导致系统资源耗尽，甚至程序崩溃。因此，我们需要在创建goroutine时控制其数量。Golang提供了一个有限的goroutine池，可以帮助我们管理goroutine的生命周期。

要使用goroutine池，我们可以使用sync包中的WaitGroup类型。WaitGroup提供了等待一组goroutine完成的机制。

import "sync"

func worker(ch chan int, wg *sync.WaitGroup) {
    // 执行一些工作
    wg.Done()  // 通知WaitGroup，当前goroutine已完成
}

func main() {
    ch := make(chan int)
    var wg sync.WaitGroup
    for i := 0; i < 10; i++ {
        wg.Add(1)  // 每创建一个goroutine，就将WaitGroup的计数器加一
        go worker(ch, &wg)  // 创建并发执行的goroutine
    }
    // 所有的goroutine已创建，等待它们全部完成
    wg.Wait()
}

在这个例子中，我们创建了一个包含10个goroutine的goroutine池。每当创建一个goroutine时，都会将WaitGroup的计数器加一。当goroutine完成工作时，需要调用WaitGroup的Done方法来通知WaitGroup，当前goroutine已经完成。最后，在main函数中，我们调用WaitGroup的Wait方法，等待所有的goroutine完成。

通过合理管理goroutine的数量，我们可以避免系统资源的浪费，并获得更好的性能和可靠性。