- Sort Score
- Num 10 results
- Language All
Results 331 - 340 of 1,200 for Ensure (0.11 seconds)
-
guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
SECONDS, new ArrayBlockingQueue<Runnable>(1000)); executorService.prestartAllCoreThreads(); AtomicInteger integer = new AtomicInteger(); // Execute a bunch of tasks to ensure that our threads are allocated and hot for (int i = 0; i < NUM_THREADS * 10; i++) { @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored Future<?> possiblyIgnoredError =Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jul 16 17:42:14 GMT 2025 - 15.8K bytes - Click Count (0) -
android/guava/src/com/google/common/hash/LittleEndianByteArray.java
return ByteOrder.nativeOrder().equals(ByteOrder.LITTLE_ENDIAN) ? UnsafeByteArray.UNSAFE_LITTLE_ENDIAN : UnsafeByteArray.UNSAFE_BIG_ENDIAN; } } catch (Throwable t) { // ensure we really catch *everything* } return JavaLittleEndianBytes.INSTANCE; } /** Deter instantiation of this class. */ private LittleEndianByteArray() {}
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 10.1K bytes - Click Count (0) -
internal/grid/README.md
The client does not wait for the remote handler to finish before returning. Returning any error will also cancel the stream remotely. CAREFUL: When utilizing two-way communication, it is important to ensure that the remote handler is not blocked on a send. If the remote handler is blocked on a send, and the client is trying to send without the remote receiving, the operation would become deadlocked if the channels are full.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 9.4K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java
childKey = child.getKey(); if (managedVersions.containsKey(childKey)) { // If this child node is a managed dependency, ensure // we are using the dependency management version // of this child if applicable b/c we want to use the
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 36.5K bytes - Click Count (0) -
src/main/java/org/codelibs/core/misc/DynamicProperties.java
* <li>{@link IORuntimeException} - Thrown if there are I/O errors during file operations.</li> * </ul> * * <p>Thread Safety: * This class uses synchronization to ensure thread-safe access to the properties. * * @see Properties */ public class DynamicProperties extends Properties { private static final long serialVersionUID = 1L; /**
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Sat Jul 05 00:11:05 GMT 2025 - 13.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/util/IpAddressUtil.java
// Utility class - no instances allowed } /** * Determines if the given address string represents an IPv6 address. * This method validates the address using InetAddress to ensure it's a valid IPv6 address. * * @param address the IP address string to check * @return true if the address is a valid IPv6 address, false otherwise */Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 06 08:31:03 GMT 2025 - 9.4K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/goals/PluginUpgradeStrategy.java
// Calculate the relative path from common root Path relativePath = commonRoot.relativize(originalPath); Path tempPomPath = tempDir.resolve(relativePath); // Ensure parent directories exist Files.createDirectories(tempPomPath.getParent()); // Write POM to temp location writePomToFile(document, tempPomPath);Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Nov 18 18:03:26 GMT 2025 - 37K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/SmbFileOutputStream.java
* * @return true if the stream is open, false otherwise */ public boolean isOpen() { return file.isOpen(); } void ensureOpen() throws IOException { // ensure file is open if (!file.isOpen()) { file.open(openFlags, access | SmbConstants.FILE_WRITE_DATA, SmbFile.ATTR_NORMAL, 0); if (append) { fp = file.length(); }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 11K bytes - Click Count (0) -
src/test/java/jcifs/internal/fscc/FsctlPipeWaitRequestTest.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 13.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/dict/mapping/CharMappingFile.java
} /** * Inner class for handling updates to the character mapping file. * This class manages the temporary file creation, writing operations, * and atomic updates to ensure data consistency during modifications. */ protected class MappingUpdater implements Closeable { /** Flag indicating whether changes should be committed to the file. */Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Dec 20 05:56:45 GMT 2025 - 15.3K bytes - Click Count (0)