Golang 関数型並行プログラミングでの単体テストのベスト プラクティス

// your_test.go

package main

import "testing"

func Benchmark(b *testing.B) {
    b.RunParallel(func(pb *testing.PB) {
        for pb.Next() {
            // 并发执行的测试逻辑
        }
    })
}

// your_test.go

package main

import (
    "testing"
    "runtime"
)

func TestConcurrency(t *testing.T) {
    runtime.GOMAXPROCS(4)
    t.Parallel()

    for i := 0; i < 100; i++ {
        go func() {
            // 并发执行的测试逻辑
        }()
    }
}

// your_test.go

package main

import (
    "testing"
    "sync"
    "time"
)

var counter int

func TestDataRace(t *testing.T) {
    var wg sync.WaitGroup

    t.Parallel()
    for i := 0; i < 100; i++ {
        wg.Add(1)
        go func() {
            // 并发访问共享变量
            for j := 0; j < 100; j++ {
                counter++
            }
            wg.Done()
        }()
    }

    wg.Wait()

    // 断言计数器不等于 10000，因为存在数据竞争
    if counter != 10000 {
        t.Fatal("数据竞争检测")
    }
}