- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 211 for refcount (2.8 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Start the task to put it in the RUNNING state. Have to use a separate // thread because the task will block on the task latch after unblocking // the run latch. exec.execute(task); runLatch.await(); assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 4.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheEvictionTest.java
assertThat(removalListener.getCount()).isEqualTo(1); // 2 will be cached assertThat(cache.getUnchecked(2)).isEqualTo(2); assertThat(cache.asMap().keySet()).containsExactly(2); CacheTesting.processPendingNotifications(cache); CacheTesting.checkValidState(cache); assertThat(removalListener.getCount()).isEqualTo(1); // 4 will be cached
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 14.9K bytes - Viewed (0) -
internal/bucket/lifecycle/filter.go
tagPred sizeLtPred sizeGtPred ) var predCount int var pType predType if !f.And.isEmpty() { pType = andPred predCount++ } if f.Prefix.set { pType = prefixPred predCount++ } if !f.Tag.IsEmpty() { pType = tagPred predCount++ } if f.ObjectSizeGreaterThan != 0 { pType = sizeGtPred predCount++ } if f.ObjectSizeLessThan != 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 27 00:01:20 UTC 2024 - 6.2K bytes - Viewed (0) -
fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
crawler1.awaitTermination(); crawler2.awaitTermination(); assertEquals(maxCount, dataService.getCount(sessionId1)); assertEquals(maxCount, dataService.getCount(sessionId2)); UrlQueue urlQueue; while ((urlQueue = urlQueueService.poll(sessionId1)) != null) { assertTrue(urlQueue.getUrl().startsWith(url1));
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 12K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
crawler1.awaitTermination(); crawler2.awaitTermination(); assertEquals(maxCount, dataService.getCount(sessionId1)); assertEquals(maxCount, dataService.getCount(sessionId2)); UrlQueue urlQueue; while ((urlQueue = urlQueueService.poll(sessionId1)) != null) { assertTrue(urlQueue.getUrl().startsWith(url1));
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 18K bytes - Viewed (0) -
platforms/software/resources/src/main/java/org/gradle/internal/resource/local/LocalFileStandInExternalResource.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 8.5K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl-tooling-builders/src/main/kotlin/org/gradle/kotlin/dsl/tooling/builders/EditorReportsBuilder.kt
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 12 19:30:55 UTC 2024 - 6.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java
assertEquals("Eviction notifications must be received", 10, removalListener.getCount()); CacheTesting.expireEntries((LoadingCache<?, ?>) cache, EXPIRING_TIME, ticker); // ensure that no new notifications are sent assertEquals("Eviction notifications must be received", 10, removalListener.getCount()); } public void testExpiringGet_expireAfterWrite() { FakeTicker ticker = new FakeTicker();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Aug 05 17:21:46 UTC 2022 - 18.7K bytes - Viewed (0) -
guava/src/com/google/common/collect/ForwardingSortedMultiset.java
if (!entryIterator.hasNext()) { return null; } Entry<E> entry = entryIterator.next(); return Multisets.immutableEntry(entry.getElement(), entry.getCount()); } @Override @CheckForNull public Entry<E> lastEntry() { return delegate().lastEntry(); } /** * A sensible definition of {@link #lastEntry()} in terms of {@code
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 15:26:39 UTC 2023 - 8.7K bytes - Viewed (0) -
guava/src/com/google/common/io/FileBackedOutputStream.java
private File file; /** ByteArrayOutputStream that exposes its internals. */ private static class MemoryOutput extends ByteArrayOutputStream { byte[] getBuffer() { return buf; } int getCount() { return count; } } /** Returns the file holding the data (possibly null). */ @VisibleForTesting @CheckForNull synchronized File getFile() { return file; } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 8.2K bytes - Viewed (0)