深入理解Go语言中切片操作与并发同步

package main

import (
    "fmt"
    "time"
)

// sendvalues 模拟向通道发送整数
func sendvalues(cs chan int) {
    for i := 0; i < 10; i++ {
        cs <- i
    }
    close(cs) // 发送完毕后关闭通道
}

// appendInt 尝试将通道中的值追加到切片
func appendInt(cs chan int, aINt []int) {
    for i := range cs { // 从通道接收值，直到通道关闭
        aINt = append(aINt, i) // 注意：append可能返回新切片
        fmt.Println("内部切片:", aINt)
    }
    // 此时，aINt可能已经是一个新的切片头部，外部的intSlice不会感知到
}

func main() {
    cs := make(chan int)
    intSlice := make([]int, 0, 10) // 初始容量10

    fmt.Println("Before:", intSlice)
    go sendvalues(cs)
    go appendInt(cs, intSlice) // intSlice的副本被传递给appendInt

    // 简单的休眠不足以保证appendInt goroutine完成
    time.Sleep(2 * time.Second)
    fmt.Println("After:", intSlice) // 外部的intSlice很可能没有被修改
}

package main

import "fmt"
import "sync" // 引入sync包用于同步

// modify 通过切片指针修改切片
func modify(s *[]int) {
    for i := 0; i < 10; i++ {
        *s = append(*s, i) // 使用*s解引用指针，修改原始切片
    }
}

func main() {
    s := []int{1, 2, 3}
    fmt.Println("Before modify:", s)
    modify(&s) // 传递切片的地址
    fmt.Println("After modify:", s)
}

package main

import (
    "fmt"
    "sync"
)

func sendvalues(cs chan int) {
    for i := 0; i < 10; i++ {
        cs <- i
    }
    close(cs)
}

// appendIntWithPointerAndSync 接收切片指针和WaitGroup
func appendIntWithPointerAndSync(wg *sync.WaitGroup, cs chan int, aINt *[]int) {
    defer wg.Done() // goroutine结束时调用Done()
    for i := range cs {
        *aINt = append(*aINt, i) // 通过指针修改原始切片
        fmt.Println("内部切片:", *aINt)
    }
}

func main() {
    cs := make(chan int)
    intSlice := make([]int, 0, 10)
    var wg sync.WaitGroup // 声明WaitGroup

    fmt.Println("Before:", intSlice)

    wg.Add(1) // 为sendvalues goroutine增加计数
    go sendvalues(cs)

    wg.Add(1) // 为appendIntWithPointerAndSync goroutine增加计数
    go appendIntWithPointerAndSync(&wg, cs, &intSlice) // 传递WaitGroup指针和切片指针

    wg.Wait() // 等待所有goroutine完成
    fmt.Println("After:", intSlice)
}

package main

import (
    "fmt"
)

// generateAndSendSlice 生成切片并将结果发送到通道
func generateAndSendSlice(res chan []int) {
    s := []int{}
    for i := 0; i < 10; i++ {
        s = append(s, i)
    }
    res <- s // 将最终的切片发送到结果通道
}

func main() {
    c := make(chan []int) // 创建一个用于接收切片的通道
    go generateAndSendSlice(c)

    // 主goroutine阻塞，直到从通道接收到切片
    finalSlice := <-c
    fmt.Println("接收到的切片:", finalSlice)
}