File size: 1,540 Bytes
6932c8c | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 | package csync
import (
"sync"
"testing"
"github.com/stretchr/testify/require"
)
func TestValue_GetSet(t *testing.T) {
t.Parallel()
v := NewValue(42)
require.Equal(t, 42, v.Get())
v.Set(100)
require.Equal(t, 100, v.Get())
}
func TestValue_ZeroValue(t *testing.T) {
t.Parallel()
v := NewValue("")
require.Equal(t, "", v.Get())
v.Set("hello")
require.Equal(t, "hello", v.Get())
}
func TestValue_Struct(t *testing.T) {
t.Parallel()
type config struct {
Name string
Count int
}
v := NewValue(config{Name: "test", Count: 1})
require.Equal(t, config{Name: "test", Count: 1}, v.Get())
v.Set(config{Name: "updated", Count: 2})
require.Equal(t, config{Name: "updated", Count: 2}, v.Get())
}
func TestValue_PointerPanics(t *testing.T) {
t.Parallel()
require.Panics(t, func() {
NewValue(&struct{}{})
})
}
func TestValue_SlicePanics(t *testing.T) {
t.Parallel()
require.Panics(t, func() {
NewValue([]string{"a", "b"})
})
}
func TestValue_MapPanics(t *testing.T) {
t.Parallel()
require.Panics(t, func() {
NewValue(map[string]int{"a": 1})
})
}
func TestValue_ConcurrentAccess(t *testing.T) {
t.Parallel()
v := NewValue(0)
var wg sync.WaitGroup
// Concurrent writers.
for i := range 100 {
wg.Add(1)
go func(val int) {
defer wg.Done()
v.Set(val)
}(i)
}
// Concurrent readers.
for range 100 {
wg.Go(func() {
_ = v.Get()
})
}
wg.Wait()
// Value should be one of the set values (0-99).
got := v.Get()
require.GreaterOrEqual(t, got, 0)
require.Less(t, got, 100)
}
|