Go语言中并发安全地操作结构体切片：引用与同步机制

type Window struct {
    Height int64 `json:"Height"`
    Width  int64 `json:"Width"`
}
type Room struct {
    Windows []Window `json:"Windows"`
}

func addWindow(windows []Window) {
    window := Window{1, 1}
    windows = append(windows, window) // 此处的windows是副本，重新分配后原切片不会改变
}

// 调用示例
// addWindow(room.Windows) // 无法修改room.Windows

func addWindow(windows []Window) []Window {
    return append(windows, Window{Height: 1, Width: 1})
}

// 调用示例
// room.Windows = addWindow(room.Windows)

func addWindow(room *Room) {
    room.Windows = append(room.Windows, Window{Height: 1, Width: 1})
}

// 调用示例
// addWindow(&room)

func createWindow(windowsChan chan<- Window) {
    // 模拟耗时计算
    window := Window{Height: 1, Width: 1}
    windowsChan <- window // 将新创建的Window发送到通道
}

func main() {
    // ... (初始化room)

    numWindowsToAdd := 10
    windowsChan := make(chan Window, numWindowsToAdd) // 创建带缓冲的通道

    var wg sync.WaitGroup
    for i := 0; i < numWindowsToAdd; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            createWindow(windowsChan) // 并发创建Window
        }()
    }
    wg.Wait()
    close(windowsChan) // 关闭通道，表示所有Window已发送

    // 主goroutine顺序地从通道接收Window并添加到room.Windows
    for newWindow := range windowsChan {
        room.Windows = append(room.Windows, newWindow)
    }

    // ... (后续处理)
}

import "sync"

type Room struct {
    m       sync.Mutex // 保护Windows切片的互斥锁
    Windows []Window   `json:"Windows"`
}

func (r *Room) AddWindow(window Window) {
    r.m.Lock()         // 获取锁，进入临界区
    defer r.m.Unlock() // 确保在函数退出时释放锁
    r.Windows = append(r.Windows, window)
}

func main() {
    // ... (初始化room)

    var wg sync.WaitGroup
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            // 模拟耗时计算
            newWindow := Window{Height: 1, Width: 1}
            room.AddWindow(newWindow) // 通过方法安全地添加窗口
        }()
    }
    wg.Wait()

    // ... (后续处理)
}

var addWindowMutex sync.Mutex // 全局互斥锁

func addWindowSafely(room *Room, window Window) {
    addWindowMutex.Lock()         // 获取全局锁
    defer addWindowMutex.Unlock() // 释放全局锁
    room.Windows = append(room.Windows, window)
}

func main() {
    // ... (初始化room)

    var wg sync.WaitGroup
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            // 模拟耗时计算
            newWindow := Window{Height: 1, Width: 1}
            addWindowSafely(&room, newWindow) // 使用全局锁保护函数调用
        }()
    }
    wg.Wait()

    // ... (后续处理)
}