Go语言中结构体并发更新失效：值拷贝陷阱与指针实践

package main

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

// Server 接口定义
type Server interface {
    GetId() int
}

// ServerInstance 结构体实现 Server 接口
type ServerInstance struct {
    Id int
}

// GetId 方法使用值接收器
func (serv ServerInstance) GetId() int {
    return serv.Id
}

// UpdateId 方法使用指针接收器，用于在协程中更新 Id
func (serv *ServerInstance) UpdateId(newId int) {
    serv.Id = newId
    fmt.Printf("Goroutine: 实例地址 %p, ID 已更新为 %d\n", serv, serv.Id)
}

func main() {
    var wg sync.WaitGroup

    // 1. 创建一个 ServerInstance 实例 (值类型)
    originalInstance := ServerInstance{Id: 100}
    fmt.Printf("主协程: 原始实例地址 %p, 初始 ID: %d\n", &originalInstance, originalInstance.Id)

    // 2. 将 originalInstance 作为 Server 接口类型的值添加到切片中
    // 注意：这里会发生值拷贝，切片中存储的是 originalInstance 的一个副本
    arr := []Server{originalInstance} // arr[0] 存储的是 originalInstance 的副本
    fmt.Printf("主协程: 切片中元素 (副本) 的 ID: %d\n", arr[0].GetId())

    // 3. 启动一个协程更新 originalInstance 的 Id
    // 注意：这里更新的是 originalInstance，而不是 arr[0] 中的副本
    wg.Add(1)
    go func() {
        defer wg.Done()
        time.Sleep(100 * time.Millisecond) // 模拟异步更新
        originalInstance.UpdateId(23445)
    }()

    // 4. 主协程尝试读取 arr[0] 的 Id
    time.Sleep(200 * time.Millisecond) // 确保协程有时间执行
    fmt.Printf("主协程: 从切片中读取的 ID: %d (未更新)\n", arr[0].GetId()) // 仍然是 100

    wg.Wait()
}

主协程: 原始实例地址 0xc000010020, 初始 ID: 100
主协程: 切片中元素 (副本) 的 ID: 100
Goroutine: 实例地址 0xc000010020, ID 已更新为 23445
主协程: 从切片中读取的 ID: 100 (未更新)

package main

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

// Server 接口定义
type Server interface {
    GetId() int
}

// ServerInstance 结构体实现 Server 接口
type ServerInstance struct {
    Id int
}

// GetId 方法使用指针接收器 (推荐，因为结构体通常通过指针管理)
func (serv *ServerInstance) GetId() int {
    return serv.Id
}

// UpdateId 方法使用指针接收器，用于在协程中更新 Id
func (serv *ServerInstance) UpdateId(newId int) {
    serv.Id = newId
    fmt.Printf("Goroutine: 实例地址 %p, ID 已更新为 %d\n", serv, serv.Id)
}

func main() {
    var wg sync.WaitGroup

    // 1. 创建一个 ServerInstance 实例的指针
    originalInstancePtr := &ServerInstance{Id: 100}
    fmt.Printf("主协程: 原始实例指针地址 %p, 初始 ID: %d\n", originalInstancePtr, originalInstancePtr.Id)

    // 2. 将 originalInstancePtr (指针) 作为 Server 接口类型的值添加到切片中
    // 注意：切片中存储的是 originalInstancePtr 指向的内存地址
    arr := []Server{originalInstancePtr} // arr[0] 存储的是 originalInstancePtr
    fmt.Printf("主协程: 切片中元素 (通过指针) 的 ID: %d\n", arr[0].GetId())

    // 3. 启动一个协程更新 originalInstancePtr 所指向的 Id
    // 注意：这里更新的是 originalInstancePtr 指向的内存中的数据
    wg.Add(1)
    go func() {
        defer wg.Done()
        time.Sleep(100 * time.Millisecond) // 模拟异步更新
        originalInstancePtr.UpdateId(23445)
    }()

    // 4. 主协程尝试读取 arr[0] 的 Id
    time.Sleep(200 * time.Millisecond) // 确保协程有时间执行
    fmt.Printf("主协程: 从切片中读取的 ID: %d (已更新)\n", arr[0].GetId()) // 应该是 23445

    wg.Wait()
}

主协程: 原始实例指针地址 0xc000010020, 初始 ID: 100
主协程: 切片中元素 (通过指针) 的 ID: 100
Goroutine: 实例地址 0xc000010020, ID 已更新为 23445
主协程: 从切片中读取的 ID: 23445 (已更新)