281 |
|
} |
282 |
|
for (int i = 0; i < SIZE; i += 2) { |
283 |
|
assertTrue(q.removeFirstOccurrence(new Integer(i))); |
284 |
< |
assertFalse(q.removeFirstOccurrence(new Integer(i+1))); |
284 |
> |
assertFalse(q.removeFirstOccurrence(new Integer(i + 1))); |
285 |
|
} |
286 |
|
assertTrue(q.isEmpty()); |
287 |
|
} |
296 |
|
} |
297 |
|
for (int i = 0; i < SIZE; i += 2) { |
298 |
|
assertTrue(q.removeLastOccurrence(new Integer(i))); |
299 |
< |
assertFalse(q.removeLastOccurrence(new Integer(i+1))); |
299 |
> |
assertFalse(q.removeLastOccurrence(new Integer(i + 1))); |
300 |
|
} |
301 |
|
assertTrue(q.isEmpty()); |
302 |
|
} |
1246 |
|
public void testTakeLast() throws InterruptedException { |
1247 |
|
LinkedBlockingDeque q = populatedDeque(SIZE); |
1248 |
|
for (int i = 0; i < SIZE; ++i) { |
1249 |
< |
assertEquals(SIZE - i-1, q.takeLast()); |
1249 |
> |
assertEquals(SIZE - i - 1, q.takeLast()); |
1250 |
|
} |
1251 |
|
} |
1252 |
|
|
1259 |
|
Thread t = newStartedThread(new CheckedRunnable() { |
1260 |
|
public void realRun() throws InterruptedException { |
1261 |
|
for (int i = 0; i < SIZE; ++i) { |
1262 |
< |
assertEquals(SIZE - i-1, q.takeLast()); |
1262 |
> |
assertEquals(SIZE - i - 1, q.takeLast()); |
1263 |
|
} |
1264 |
|
|
1265 |
|
Thread.currentThread().interrupt(); |
1289 |
|
public void testTimedPollLast0() throws InterruptedException { |
1290 |
|
LinkedBlockingDeque q = populatedDeque(SIZE); |
1291 |
|
for (int i = 0; i < SIZE; ++i) { |
1292 |
< |
assertEquals(SIZE - i-1, q.pollLast(0, MILLISECONDS)); |
1292 |
> |
assertEquals(SIZE - i - 1, q.pollLast(0, MILLISECONDS)); |
1293 |
|
} |
1294 |
|
assertNull(q.pollLast(0, MILLISECONDS)); |
1295 |
|
} |
1301 |
|
LinkedBlockingDeque q = populatedDeque(SIZE); |
1302 |
|
for (int i = 0; i < SIZE; ++i) { |
1303 |
|
long startTime = System.nanoTime(); |
1304 |
< |
assertEquals(SIZE - i-1, q.pollLast(LONG_DELAY_MS, MILLISECONDS)); |
1304 |
> |
assertEquals(SIZE - i - 1, q.pollLast(LONG_DELAY_MS, MILLISECONDS)); |
1305 |
|
assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); |
1306 |
|
} |
1307 |
|
long startTime = System.nanoTime(); |
1320 |
|
public void realRun() throws InterruptedException { |
1321 |
|
LinkedBlockingDeque q = populatedDeque(SIZE); |
1322 |
|
for (int i = 0; i < SIZE; ++i) { |
1323 |
< |
assertEquals(SIZE - i-1, q.pollLast(LONG_DELAY_MS, MILLISECONDS)); |
1323 |
> |
assertEquals(SIZE - i - 1, |
1324 |
> |
q.pollLast(LONG_DELAY_MS, MILLISECONDS)); |
1325 |
|
} |
1326 |
|
|
1327 |
|
Thread.currentThread().interrupt(); |