Go语言中包级别变量的并发安全性与实践

package main

import (
    "fmt"
    "net/http"
    "time"
)

var CurrentUser *string // 这是一个包级别变量，用于存储当前用户

func handler(w http.ResponseWriter, r *http.Request) {
    user := r.URL.Query().Get("user")
    fmt.Printf("请求开始，用户: %s\n", user)

    // 将当前用户设置到包级别变量
    CurrentUser = &user
    fmt.Printf("CurrentUser 被设置为: %s\n", *CurrentUser)

    // 模拟一个耗时操作，例如数据库查询或外部API调用
    time.Sleep(100 * time.Millisecond)

    // 在耗时操作后，尝试读取CurrentUser
    // 此时 CurrentUser 可能已经被其他请求修改
    fmt.Fprintf(w, "Hello, %s! 您的 CurrentUser 在处理结束时是: %s\n", user, *CurrentUser)
    fmt.Printf("请求结束，用户: %s, 最终 CurrentUser: %s\n", user, *CurrentUser)
}

func main() {
    http.HandleFunc("/", handler)
    fmt.Println("服务器启动，监听 :8080")
    // 访问示例：
    // http://localhost:8080/?user=John
    // http://localhost:8080/?user=Fred
    // 快速连续访问这两个URL，观察输出
    http.ListenAndServe(":8080", nil)
}

package main

import (
    "fmt"
    "net/http"
    "time"
)

// 不再使用包级别变量 CurrentUser

func handlerSafe(w http.ResponseWriter, r *http.Request) {
    user := r.URL.Query().Get("user") // user 是局部变量
    fmt.Printf("请求开始，用户: %s\n", user)

    // 所有操作都基于局部变量 user
    fmt.Printf("处理中，当前用户: %s\n", user)

    // 模拟耗时操作
    time.Sleep(100 * time.Millisecond)

    // 在耗时操作后读取局部变量 user
    // 局部变量 user 不会受到其他请求的影响
    fmt.Fprintf(w, "Hello, %s! 您的原始用户是: %s\n", user, user)
    fmt.Printf("请求结束，用户: %s\n", user)
}

func main() {
    http.HandleFunc("/safe", handlerSafe)
    fmt.Println("服务器启动，监听 :8080")
    // 访问示例：
    // http://localhost:8080/safe?user=John
    // http://localhost:8080/safe?user=Fred
    // 快速连续访问这两个URL，观察输出，每次都能正确显示对应用户
    http.ListenAndServe(":8080", nil)
}

package main

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

var (
    globalCounter int
    mu            sync.Mutex // 互斥锁，用于保护 globalCounter
)

func incrementCounter() {
    mu.Lock()         // 加锁，确保只有一个goroutine可以修改 globalCounter
    defer mu.Unlock() // 延迟解锁
    globalCounter++
}

func main() {
    var wg sync.WaitGroup
    for i := 0; i < 1000; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            incrementCounter()
        }()
    }
    wg.Wait()
    fmt.Println("最终全局计数器值:", globalCounter) // 期望是1000
}