Lines Matching refs:TASKS
274 * when tasks complete
465 * getTaskCount increases, but doesn't overestimate, when tasks submitted
561 * getQueue returns the work queue, which contains queued tasks
572 FutureTask[] tasks = new FutureTask[5];
573 for (int i = 0; i < tasks.length; i++) {
581 tasks[i] = new FutureTask(task);
582 p.execute(tasks[i]);
586 assertFalse(q.contains(tasks[0]));
587 assertTrue(q.contains(tasks[tasks.length - 1]));
588 assertEquals(tasks.length - 1, q.size());
604 Runnable[] tasks = new Runnable[6];
608 for (int i = 0; i < tasks.length; i++) {
609 tasks[i] = new CheckedRunnable() {
614 p.execute(tasks[i]);
617 assertFalse(p.remove(tasks[0]));
618 assertTrue(q.contains(tasks[4]));
619 assertTrue(q.contains(tasks[3]));
620 assertTrue(p.remove(tasks[4]));
621 assertFalse(p.remove(tasks[4]));
622 assertFalse(q.contains(tasks[4]));
623 assertTrue(q.contains(tasks[3]));
624 assertTrue(p.remove(tasks[3]));
625 assertFalse(q.contains(tasks[3]));
633 * purge removes cancelled tasks from the queue
643 FutureTask[] tasks = new FutureTask[5];
645 for (int i = 0; i < tasks.length; i++) {
652 tasks[i] = new FutureTask(task);
653 p.execute(tasks[i]);
656 assertEquals(tasks.length, p.getTaskCount());
657 assertEquals(tasks.length - 1, q.size());
660 tasks[4].cancel(true);
661 tasks[3].cancel(false);
663 assertEquals(tasks.length - 3, q.size());
664 assertEquals(tasks.length - 2, p.getTaskCount());
666 assertEquals(tasks.length - 3, q.size());
667 assertEquals(tasks.length - 2, p.getTaskCount());
675 * shutdownNow returns a list containing tasks that were not run
1021 TrackedNoOpRunnable[] tasks = new TrackedNoOpRunnable[5];
1022 for (int i = 0; i < tasks.length; ++i)
1023 tasks[i] = new TrackedNoOpRunnable();
1026 for (int i = 0; i < tasks.length; ++i)
1027 p.execute(tasks[i]);
1028 for (int i = 1; i < tasks.length; ++i)
1029 assertTrue(tasks[i].done);
1047 TrackedNoOpRunnable[] tasks = new TrackedNoOpRunnable[5];
1048 for (int i = 0; i < tasks.length; ++i)
1049 tasks[i] = new TrackedNoOpRunnable();
1051 for (TrackedNoOpRunnable task : tasks)
1053 for (TrackedNoOpRunnable task : tasks)
1448 * invokeAll(c) returns results of all completed tasks
1642 * timed invokeAll(c) returns results of all completed tasks
1661 * timed invokeAll(c) cancels tasks not completed by timeout
1693 final int TASKS = 100;
1694 final CountDownLatch done = new CountDownLatch(TASKS);
1695 for (int k = 0; k < TASKS; ++k)
