Searched refs:nTasks (Results 1 – 5 of 5) sorted by relevance
122 int nTasks = mPollingTasks.size(); in add() local123 logger.print("Before add(), the existing tasks number: " + nTasks); in add()175 if (nTasks <= 0) { in add()188 int nTasks = mPollingTasks.size(); in remove() local189 if (nTasks <= 0) { in remove()195 for (int i = 0; i < nTasks; i++) { in remove()224 int nTasks = mPollingTasks.size(); in retry() local225 if (nTasks <= 0) { in retry()230 for (int i = 0; i < nTasks; i++) { in retry()
68 int nTasks = nThreads * tasksPerThread; in testAddAndRemove() local72 List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks); in testAddAndRemove()73 for (int i = 0; i < nTasks; i++) { in testAddAndRemove()
126 int nTasks = 1000; in testRemovalNotification_clear_basher() local128 Set<String> expectedKeys = Sets.newHashSetWithExpectedSize(nTasks + nSeededEntries); in testRemovalNotification_clear_basher()139 final CountDownLatch tasksFinished = new CountDownLatch(nTasks); in testRemovalNotification_clear_basher()140 for (int i = 0; i < nTasks; i++) { in testRemovalNotification_clear_basher()
463 int nTasks = 1000; in testRemovalNotification_clear_basher() local465 Set<String> expectedKeys = Sets.newHashSetWithExpectedSize(nTasks + nSeededEntries); in testRemovalNotification_clear_basher()477 final CountDownLatch tasksFinished = new CountDownLatch(nTasks); in testRemovalNotification_clear_basher()478 for (int i = 0; i < nTasks; i++) { in testRemovalNotification_clear_basher()527 int nTasks = 1000; in testRemovalNotification_get_basher() local566 for (int i = 0; i < nTasks; i++) { in testRemovalNotification_get_basher()
559 int nTasks = 3000; in testModify_basher() local569 for (int i = 0; i < nTasks; i++) { in testModify_basher()