Go 协程的基准测试：性能表现的深入分析

package main

import (
    "fmt"
    "runtime/pprof"
    "testing"
)

func TestGoroutine(b *testing.B) {
    for i := 0; i < b.N; i++ {
        go func() {
            fmt.Println("Hello, world!")
        }()
    }
}

func main() {
    f, _ := os.Create("goroutine.prof")
    pprof.StartCPUProfile(f)
    defer pprof.StopCPUProfile()
    testing.Main(m.Run, m.SetOutput, m.VerboseFlag, m.readFileSyncFlag)
}

package main

import (
    "fmt"
    "runtime/pprof"
    "strings"
    "testing"
    "time"
)

func TestConcurrency(b *testing.B) {
    for numWorkers := 1; numWorkers <= 1000; numWorkers++ {
        for bufferSize := 1; bufferSize <= 1000; bufferSize++ {

            for tests := 0; tests < b.N; tests++ {
                c := make(chan int, bufferSize)

                go func() {
                    for n := 0; n < 1000000; n++ {
                        c <- n
                    }
                    close(c)
                }()

                var results []int

                for {
                    r, ok := <-c
                    if !ok {
                        break
                    }
                    results = append(results, r)
                }

                readValues := strings.Join(strings.Split(fmt.Sprint(results), " "), ", ")
                b.Logf("Concurrency: %d, BufferSize: %d, ReadValues: %s, ", numWorkers, bufferSize, readValues)
            }
        }
    }
}

func main() {
    f, _ := os.Create("concurrency.prof")
    pprof.StartCPUProfile(f)
    defer pprof.StopCPUProfile()
    testing.Main(m.Run, m.SetOutput, m.VerboseFlag, m.readFileSyncFlag)
}