分布式Golang API的性能调优指南

package main

import (
    "fmt"
    "runtime"
)

func main() {
    fmt.Println("Current goroutine count:", runtime.NumGoroutine())

    // 创建 100 个协程
    for i := 0; i < 100; i++ {
        go func() {
            fmt.Println("Hello from goroutine", i)
        }()
    }

    fmt.Println("Current goroutine count:", runtime.NumGoroutine())
}

package main

import (
    "fmt"
    "sync"
    "time"
)

func main() {
    c := make(chan int) // 创建一个整数通道

    var wg sync.WaitGroup // 创建一个等待组

    // 启动 10 个协程将数字发送到通道
    for i := 0; i < 10; i++ {
        wg.Add(1) // 向等待组中添加一个协程

        go func(i int) {
            defer wg.Done() // 完成协程时从中减去 1
            c <- i
        }(i)
    }

    // 启动一个协程从通道中接收数字
    go func() {
        for i := range c {
            fmt.Println("Received", i)
        }
    }()

    // 等待所有协程完成
    wg.Wait()
}

package main

import (
    "fmt"
    "time"
)

var cache = map[string]string{} // 创建一个字符串到字符串的映射作为缓存

func main() {
    // 从数据库获取数据
    data := "Some data from database"

    // 将数据添加到缓存中
    cache["key"] = data

    // 从缓存中获取数据
    cachedData := cache["key"]

    fmt.Println("Cached data:", cachedData)

    // 设置缓存过期时间
    go func() {
        time.Sleep(time.Minute) // 1 分钟后
        delete(cache, "key")  // 从缓存中删除键
    }()
}