@@ -40,7 +40,7 @@ func TestLevelQueue(t *testing.T) {
40
40
BatchLength : 2 ,
41
41
BlockTimeout : 1 * time .Second ,
42
42
BoostTimeout : 5 * time .Minute ,
43
- BoostWorkers : 5 ,
43
+ BoostWorkers : 0 ,
44
44
MaxWorkers : 10 ,
45
45
},
46
46
Workers : 1 ,
@@ -72,10 +72,6 @@ func TestLevelQueue(t *testing.T) {
72
72
result1 := <- handleChan
73
73
result2 := <- handleChan
74
74
75
- if result1 .TestString != test1 .TestString {
76
- result1 , result2 = result2 , result1
77
- }
78
-
79
75
assert .Equal (t , test1 .TestString , result1 .TestString )
80
76
assert .Equal (t , test1 .TestInt , result1 .TestInt )
81
77
@@ -118,7 +114,7 @@ func TestLevelQueue(t *testing.T) {
118
114
BatchLength : 2 ,
119
115
BlockTimeout : 1 * time .Second ,
120
116
BoostTimeout : 5 * time .Minute ,
121
- BoostWorkers : 5 ,
117
+ BoostWorkers : 0 ,
122
118
MaxWorkers : 10 ,
123
119
},
124
120
Workers : 1 ,
@@ -139,10 +135,11 @@ func TestLevelQueue(t *testing.T) {
139
135
})
140
136
141
137
result3 := <- handleChan
138
+ result4 := <- handleChan
139
+
142
140
assert .Equal (t , test1 .TestString , result3 .TestString )
143
141
assert .Equal (t , test1 .TestInt , result3 .TestInt )
144
142
145
- result4 := <- handleChan
146
143
assert .Equal (t , test2 .TestString , result4 .TestString )
147
144
assert .Equal (t , test2 .TestInt , result4 .TestInt )
148
145
0 commit comments