Golang函数的并发处理方法

在Go语言中，函数的并发处理是其一大特色，它能够充分利用多核处理器的优势，提高程序的性能和效率。本文将介绍几种常见的Golang函数并发处理方法。

Go语言通过go关键字来实现并发。当在函数调用前加上go关键字时，该函数就会在一个新的goroutine中异步执行。例如：

func printNumbers() {
    for i := 1; i <= 10; i++ {
       fmt.Println(i)
    }
}

func main() {
    go printNumbers()
    // 这里可以继续执行其他代码
    time.Sleep(time.Second)
}

在上述代码中，printNumbers函数会在一个新的goroutine中执行，而main函数会继续往下执行。

然而，仅仅使用go关键字可能会导致主程序过早结束，因为main函数结束时，整个程序就会退出。为了解决这个问题，我们可以使用channel来进行同步。channel是Go语言中用于goroutine之间通信的一种机制。

func sum(numbers []int, c chan int) {
    total := 0
    for _, num := range numbers {
       total += num
    }
    c <- total
}

func main() {
    numbers := []int{1, 2, 3, 4, 5}
    c := make(chan int)
    go sum(numbers, c)
    result := <-c
    fmt.Println(result)
}

在这个例子中，sum函数计算数组的总和，并将结果发送到channel中，main函数从channel中接收结果。

另外，Go语言还提供了sync.WaitGroup来等待一组goroutine完成。通过Add方法添加要等待的goroutine数量，Done方法表示一个goroutine完成，Wait方法会阻塞直到所有的goroutine都完成。

func process(i int, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Println(i)
}

func main() {
    var wg sync.WaitGroup
    for i := 0; i < 10; i++ {
       wg.Add(1)
       go process(i, &wg)
    }
    wg.Wait()
}

Golang提供了多种函数并发处理的方法，开发者可以根据具体需求选择合适的方式来实现高效的并发程序。