- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 411 for ensures (0.16 sec)
-
guava/src/com/google/common/base/FinalizableReferenceQueue.java
* // You might also share this between several objects. * * private static final Set<Reference<?>> references = Sets.newConcurrentHashSet(); * // This ensures that the FinalizablePhantomReference itself is not garbage-collected. * * private final ServerSocket serverSocket; * * private MyServer(...) { * ... * this.serverSocket = new ServerSocket(...);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 14.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
ListenableFuture<? extends V>... futures) { ListenableFuture<List<@Nullable V>> nullable = new ListFuture<V>(ImmutableList.copyOf(futures), true); // allAsList ensures that it fills the output list with V instances. @SuppressWarnings("nullness") ListenableFuture<List<V>> nonNull = nullable; return nonNull; } /**
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableList.java
hashCode = ~~hashCode; // needed to deal with GWT integer overflow } return hashCode; } /* * Serializes ImmutableLists as their logical contents. This ensures that * implementation types do not leak into the serialized representation. */ @J2ktIncompatible // serialization static final class SerializedForm implements Serializable { final Object[] elements;Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 17:50:58 UTC 2025 - 27.5K bytes - Viewed (0) -
src/test/java/jcifs/config/DelegatingConfigurationTest.java
import jcifs.BaseTest; import jcifs.Configuration; import jcifs.DialectVersion; import jcifs.ResolverType; /** * Comprehensive test suite for DelegatingConfiguration class. * Tests the delegation pattern and ensures all methods properly delegate. */ @DisplayName("DelegatingConfiguration Tests") class DelegatingConfigurationTest extends BaseTest { @Mock private Configuration mockDelegate;Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 20.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
} if (exitCode != Constants.EXIT_OK) { System.exit(exitCode); } } /** * Destroys the DI container and stops the timeout manager. * This method ensures proper cleanup of resources when the crawler shuts down. * It's called both during normal shutdown and in error conditions. */ private static void destroyContainer() { if (running.getAndSet(false)) {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 31.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbRandomAccessFile.java
return this.handle; } return this.handle.acquire(); } /** * Ensures that the file descriptor is openend * * @throws CIFSException if an error occurs opening the file */ public void open() throws CIFSException { try (SmbFileHandleImpl fh = ensureOpen()) {} }Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 18.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/HashBiMap.java
Arrays.fill(result, oldSize, newSize, ABSENT); return result; } @Override public int size() { return size; } /** * Ensures that all of the internal structures in the HashBiMap are ready for this many elements. */ private void ensureCapacity(int minCapacity) { if (nextInBucketKToV.length < minCapacity) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Dec 16 14:46:34 UTC 2025 - 37.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
*/ void checkAcquiredLock(Policy policy, LockGraphNode acquiredLock) { // checkAcquiredLock() should never be invoked by a lock that has already // been acquired. For unordered locks, aboutToAcquire() ensures this by // checking isAcquiredByCurrentThread(). For ordered locks, however, this // can happen because multiple locks may share the same LockGraphNode. InRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 17:06:34 UTC 2025 - 35.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java
if (crawlingInfo.getCreatedTime() == null) { crawlingInfo.setCreatedTime(now); } } /** * Sets up the conditions for deleting a crawling information record. * Ensures all associated CrawlingInfoParam records are deleted first to maintain referential integrity. * * @param crawlingInfo the crawling information entity to prepare for deletion */
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
* no service under management. Listeners would never fire because the ServiceManager was healthy * and stopped at the same time. This test ensures that listeners fire and isHealthy makes sense. */ public void testEmptyServiceManager() { Logger logger = Logger.getLogger(ServiceManager.class.getName()); logger.setLevel(Level.FINEST);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 17:49:12 UTC 2025 - 25.5K bytes - Viewed (0)