| 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 |
|
|
| |
| for i := range 100 { |
| wg.Add(1) |
| go func(val int) { |
| defer wg.Done() |
| v.Set(val) |
| }(i) |
| } |
|
|
| |
| for range 100 { |
| wg.Go(func() { |
| _ = v.Get() |
| }) |
| } |
|
|
| wg.Wait() |
|
|
| |
| got := v.Get() |
| require.GreaterOrEqual(t, got, 0) |
| require.Less(t, got, 100) |
| } |
|
|
