@@ -125,11 +125,11 @@ private void testMultipleProducers(BlockingQueue<Object> q) throws InterruptedEx
125
125
126
126
public void testDrainTimesOut () throws Exception {
127
127
for (BlockingQueue <Object > q : blockingQueues ()) {
128
- testDrainTimesOut (q );
128
+ checkDrainTimesOut (q );
129
129
}
130
130
}
131
131
132
- private void testDrainTimesOut (BlockingQueue <Object > q ) throws Exception {
132
+ private void checkDrainTimesOut (BlockingQueue <Object > q ) throws Exception {
133
133
for (boolean interruptibly : new boolean [] {true , false }) {
134
134
assertEquals (0 , Queues .drain (q , ImmutableList .of (), 1 , 10 , MILLISECONDS ));
135
135
@@ -157,11 +157,11 @@ private void testDrainTimesOut(BlockingQueue<Object> q) throws Exception {
157
157
158
158
public void testZeroElements () throws Exception {
159
159
for (BlockingQueue <Object > q : blockingQueues ()) {
160
- testZeroElements (q );
160
+ checkZeroElements (q );
161
161
}
162
162
}
163
163
164
- private void testZeroElements (BlockingQueue <Object > q ) throws InterruptedException {
164
+ private void checkZeroElements (BlockingQueue <Object > q ) throws InterruptedException {
165
165
for (boolean interruptibly : new boolean [] {true , false }) {
166
166
// asking to drain zero elements
167
167
assertEquals (0 , drain (q , ImmutableList .of (), 0 , 10 , MILLISECONDS , interruptibly ));
@@ -170,21 +170,21 @@ private void testZeroElements(BlockingQueue<Object> q) throws InterruptedExcepti
170
170
171
171
public void testEmpty () throws Exception {
172
172
for (BlockingQueue <Object > q : blockingQueues ()) {
173
- testEmpty (q );
173
+ checkEmpty (q );
174
174
}
175
175
}
176
176
177
- private void testEmpty (BlockingQueue <Object > q ) {
177
+ private void checkEmpty (BlockingQueue <Object > q ) {
178
178
assertDrained (q );
179
179
}
180
180
181
181
public void testNegativeMaxElements () throws Exception {
182
182
for (BlockingQueue <Object > q : blockingQueues ()) {
183
- testNegativeMaxElements (q );
183
+ checkNegativeMaxElements (q );
184
184
}
185
185
}
186
186
187
- private void testNegativeMaxElements (BlockingQueue <Object > q ) throws InterruptedException {
187
+ private void checkNegativeMaxElements (BlockingQueue <Object > q ) throws InterruptedException {
188
188
@ SuppressWarnings ("unused" ) // https://errorprone.info/bugpattern/FutureReturnValueIgnored
189
189
Future <?> possiblyIgnoredError = threadPool .submit (new Producer (q , 1 ));
190
190
@@ -199,11 +199,11 @@ private void testNegativeMaxElements(BlockingQueue<Object> q) throws Interrupted
199
199
200
200
public void testDrain_throws () throws Exception {
201
201
for (BlockingQueue <Object > q : blockingQueues ()) {
202
- testDrain_throws (q );
202
+ checkDrainThrows (q );
203
203
}
204
204
}
205
205
206
- private void testDrain_throws (BlockingQueue <Object > q ) {
206
+ private void checkDrainThrows (BlockingQueue <Object > q ) {
207
207
@ SuppressWarnings ("unused" ) // https://errorprone.info/bugpattern/FutureReturnValueIgnored
208
208
Future <?> possiblyIgnoredError = threadPool .submit (new Interrupter (currentThread ()));
209
209
try {
@@ -215,11 +215,11 @@ private void testDrain_throws(BlockingQueue<Object> q) {
215
215
216
216
public void testDrainUninterruptibly_doesNotThrow () throws Exception {
217
217
for (BlockingQueue <Object > q : blockingQueues ()) {
218
- testDrainUninterruptibly_doesNotThrow (q );
218
+ testDrainUninterruptiblyDoesNotThrow (q );
219
219
}
220
220
}
221
221
222
- private void testDrainUninterruptibly_doesNotThrow (final BlockingQueue <Object > q ) {
222
+ private void testDrainUninterruptiblyDoesNotThrow (final BlockingQueue <Object > q ) {
223
223
final Thread mainThread = currentThread ();
224
224
@ SuppressWarnings ("unused" ) // https://errorprone.info/bugpattern/FutureReturnValueIgnored
225
225
Future <?> possiblyIgnoredError =
0 commit comments