golang如何实现高并发 - 问答

Golang通过Goroutine和Channel来实现高并发。

Goroutine是Golang中轻量级的线程，可以同时执行多个Goroutine，且切换开销很小。通过关键字go可以创建一个新的Goroutine。例如：

go func() {
    // 这里是并发执行的代码
}()

Channel是Golang中用于Goroutine之间进行通信和同步的管道。通过Channel，可以在Goroutine之间传递数据。Channel提供了阻塞发送和接收数据的机制，保证了并发安全。例如：

ch := make(chan int)  // 创建一个整数类型的Channel

go func() {
    ch <- 42  // 向Channel发送数据
}()

result := <-ch  // 从Channel接收数据

使用Goroutine和Channel可以实现高并发的程序。可以将需要并发执行的任务封装到一个Goroutine中，并通过Channel进行数据传递和同步。同时，使用合适的并发控制机制（如WaitGroup和Mutex）可以更好地管理并发执行的Goroutine。

以下是一个简单的示例，使用Goroutine和Channel实现高并发的计数器：

package main

import (
    "fmt"
    "sync"
)

func main() {
    counter := make(chan int)
    var wg sync.WaitGroup

    for i := 0; i < 100; i++ {
        wg.Add(1)
        go func() {
            counter <- 1
            wg.Done()
        }()
    }

    go func() {
        wg.Wait()
        close(counter)
    }()

    sum := 0
    for n := range counter {
        sum += n
    }

    fmt.Println(sum)
}

该示例中，创建了一个大小为100的Channel作为计数器。通过100个Goroutine向计数器发送数字1，并通过WaitGroup进行同步。最后，通过循环从计数器中接收数据，累加到sum中。最终输出结果为100。

0 赞

0 踩