Go语言中并发更新结构体字段的可见性问题与指针应用

package main

import (
    "fmt"
    "time"
)

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

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

// GetId 方法，值接收者，返回 Id
func (s ServerInstance) GetId() int {
    return s.Id
}

// UpdateId 方法，指针接收者，用于更新 Id
func (s *ServerInstance) UpdateId(newId int) {
    s.Id = newId
    // fmt.Printf("Goroutine: Updated ID to %d\n", s.Id) // 调试输出
}

func main() {
    var servers []Server // 存储 Server 接口类型的切片

    // 创建一个 ServerInstance 实例
    instance1 := ServerInstance{Id: 100}

    // 启动一个 goroutine 持续更新 instance1 的 Id
    go func(s *ServerInstance) {
        for i := 0; i < 5; i++ {
            time.Sleep(50 * time.Millisecond)
            s.UpdateId(s.Id + 1) // 每次加1
        }
    }(&instance1) // 注意这里传递的是 instance1 的地址

    // 将 instance1 添加到切片中
    // 关键点：这里添加的是 instance1 的一个 *副本*
    servers = append(servers, instance1)

    // 稍作等待，让 goroutine 有机会更新 Id
    time.Sleep(100 * time.Millisecond)

    fmt.Println("--- 第一次检查 ---")
    for i, s := range servers {
        // 观察到的 ID 往往不是 goroutine 更新后的值
        fmt.Printf("Server[%d] ID: %d\n", i, s.GetId())
    }

    time.Sleep(300 * time.Millisecond) // 再次等待
    fmt.Println("\n--- 第二次检查 ---")
    for i, s := range servers {
        fmt.Printf("Server[%d] ID: %d\n", i, s.GetId())
    }
    // 预期：ID 应该随着 goroutine 的更新而改变
    // 实际：ID 保持不变（为100或接近100的某个值，取决于 append 时刻的副本）
}

package main

import (
    "fmt"
    "time"
)

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

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

// GetId 方法，现在使用指针接收者，确保方法操作的是同一个实例
// 尽管对于只读操作，值接收者也可以，但为了保持一致性，且如果接口方法可能需要修改数据，则推荐指针接收者
func (s *ServerInstance) GetId() int {
    return s.Id
}

// UpdateId 方法，指针接收者，用于更新 Id
func (s *ServerInstance) UpdateId(newId int) {
    s.Id = newId
    // fmt.Printf("Goroutine: Updated ID to %d\n", s.Id) // 调试输出
}

func main() {
    var servers []Server // 存储 Server 接口类型的切片

    // 创建一个 ServerInstance 实例的指针
    instance1Ptr := &ServerInstance{Id: 100} // 使用 & 获取结构体的指针

    // 启动一个 goroutine 持续更新 instance1Ptr 指向的 Id
    go func(s *ServerInstance) {
        for i := 0; i < 5; i++ {
            time.Sleep(50 * time.Millisecond)
            s.UpdateId(s.Id + 1) // 每次加1
        }
    }(instance1Ptr) // 这里直接传递 instance1Ptr

    // 将 instance1Ptr 添加到切片中
    // 关键点：这里添加的是 instance1Ptr，即一个指向原始 ServerInstance 的指针
    servers = append(servers, instance1Ptr) // 接口现在存储的是指针的副本

    // 稍作等待，让 goroutine 有机会更新 Id
    time.Sleep(100 * time.Millisecond)

    fmt.Println("--- 第一次检查 (使用指针) ---")
    for i, s := range servers {
        // 现在，GetId() 将通过指针访问到被 goroutine 更新后的值
        fmt.Printf("Server[%d] ID: %d\n", i, s.GetId())
    }

    time.Sleep(300 * time.Millisecond) // 再次等待
    fmt.Println("\n--- 第二次检查 (使用指针) ---")
    for i, s := range servers {
        fmt.Printf("Server[%d] ID: %d\n", i, s.GetId())
    }
    // 预期：ID 将随着 goroutine 的更新而改变
}