Searched refs:nTasks (Results 1 – 9 of 9) sorted by relevance
122 int nTasks = mPollingTasks.size(); in add() local123 logger.print("Before add(), the existing tasks number: " + nTasks); in add()176 if (nTasks <= 0) { in add()189 int nTasks = mPollingTasks.size(); in remove() local190 if (nTasks <= 0) { in remove()196 for (int i = 0; i < nTasks; i++) { in remove()225 int nTasks = mPollingTasks.size(); in retry() local226 if (nTasks <= 0) { in retry()231 for (int i = 0; i < nTasks; i++) { in retry()
66 int nTasks = nThreads * tasksPerThread; in testAddAndRemove() local70 List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks); in testAddAndRemove()71 for (int i = 0; i < nTasks; i++) { in testAddAndRemove()
40 int nTasks = 3000; in testModify_basher() local50 for (int i = 0; i < nTasks; i++) { in testModify_basher()
489 int nTasks = 1000; in testRemovalNotification_clear_basher() local491 Set<String> expectedKeys = Sets.newHashSetWithExpectedSize(nTasks + nSeededEntries); in testRemovalNotification_clear_basher()503 final CountDownLatch tasksFinished = new CountDownLatch(nTasks); in testRemovalNotification_clear_basher()504 for (int i = 0; i < nTasks; i++) { in testRemovalNotification_clear_basher()559 int nTasks = 1000; in testRemovalNotification_get_basher() local600 for (int i = 0; i < nTasks; i++) { in testRemovalNotification_get_basher()
281 val nTasks = 10 in <lambda>() constant284 repeat(nTasks) { in <lambda>()303 assertEquals(nTasks, taskEnded) in <lambda>()
565 int nTasks = 1000; in testRemovalNotification_clear_basher() local567 Set<String> expectedKeys = Sets.newHashSetWithExpectedSize(nTasks + nSeededEntries); in testRemovalNotification_clear_basher()579 final CountDownLatch tasksFinished = new CountDownLatch(nTasks); in testRemovalNotification_clear_basher()580 for (int i = 0; i < nTasks; i++) { in testRemovalNotification_clear_basher()635 int nTasks = 1000; in testRemovalNotification_get_basher() local676 for (int i = 0; i < nTasks; i++) { in testRemovalNotification_get_basher()
302 val nTasks = 10 in <lambda>() constant309 assertEquals(nTasks, taskEnded) in <lambda>()313 repeat(nTasks) { in <lambda>()