cubefs
67 строк · 1.6 Кб
1// Copyright 2023 The CubeFS Authors.
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7// http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
12// implied. See the License for the specific language governing
13// permissions and limitations under the License.
14
15package unboundedchan
16
17import (
18"sync"
19"testing"
20)
21
22func TestWriteReadUnboundedChan(t *testing.T) {
23// concurrent write and read unbounded chan
24UChan := NewUnboundedChan(10)
25var wg sync.WaitGroup
26for i := 0; i < 100; i++ {
27wg.Add(1)
28go func(i int) {
29defer wg.Done()
30t.Logf("In <- %v", i)
31UChan.In <- i
32}(i)
33}
34
35var wg2 sync.WaitGroup
36wg2.Add(1)
37go func() {
38defer wg2.Done()
39var total int
40values := make(map[int]int)
41for v := range UChan.Out {
42val, ok := v.(int)
43t.Logf("val(%v), ok(%v)", val, ok)
44v1, ok := values[val]
45if ok {
46t.Fatalf("value(%v) is not expected to be in UnboundedChan multiple times", v1)
47} else {
48values[val] = val
49}
50if v1 >= 100 || v1 < 0 {
51t.Fatalf("value(%v) is expected in range 0-99", v1)
52}
53total++
54}
55if total != 100 {
56t.Fatalf("expected total num(%v), got(%v)", 100, total)
57}
58t.Logf("total: %v", total)
59}()
60
61wg.Wait()
62close(UChan.In)
63t.Logf("UChan closed")
64
65wg2.Wait()
66t.Logf("finish")
67}
68