Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 331 - 340 of 1,200 for Ensure (0.11 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. src/test/java/jcifs/internal/fscc/FsctlPipeWaitRequestTest.java

            int[] offsets = { 0, 1, 10, 50, 100 };
    
            for (int offset : offsets) {
                byte[] buffer = new byte[200];
                // Fill buffer with pattern to ensure proper writing
                for (int i = 0; i < buffer.length; i++) {
                    buffer[i] = (byte) 0xFF;
                }
    
                int bytesEncoded = request.encode(buffer, offset);
    
    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)
  10. 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)
Back to Top