Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 441 - 450 of 659 for consumer (0.05 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

       * Delays, via Thread.sleep, for the given millisecond delay, but if the sleep is shorter than
       * specified, may re-sleep or yield until time elapses.
       */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait?
      static void delay(long millis) throws InterruptedException {
        long startTime = System.nanoTime();
        long ns = millis * 1000 * 1000;
        for (; ; ) {
          if (millis > 0L) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.8K bytes
    - Click Count (0)
  2. api/maven-api-core/src/main/java/org/apache/maven/api/package-info.java

     * from a Project Object Model (POM).</p>
     *
     * <p><dfn>Project Object Model</dfn> or <dfn>POM</dfn> refers to the information describing
     * all the information needed to build or consume a project. Those are usually loaded from
     * a file named {@code pom.xml} and loaded into a {@link org.apache.maven.api.model.Model Model}
     * instances.</p>
     *
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Dec 15 11:13:42 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/io/Files.java

        if (parent == null) {
          /*
           * The given directory is a filesystem root. All zero of its ancestors exist. This doesn't
           * mean that the root itself exists -- consider x:\ on a Windows machine without such a drive
           * -- or even that the caller can create it, but this method makes no such guarantees even for
           * non-root files.
           */
          return;
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Jan 05 22:13:21 GMT 2026
    - 32.8K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/CipherSuiteTest.kt

       * On the Oracle JVM some older cipher suites have the "SSL_" prefix and others have the "TLS_"
       * prefix. On the IBM JVM all cipher suites have the "SSL_" prefix.
       *
       * Prior to OkHttp 3.3.1 we accepted either form and consider them equivalent. And since OkHttp
       * 3.7.0 this is also true. But OkHttp 3.3.1 through 3.6.0 treated these as different.
       */
      @Test
      fun forJavaName_fromLegacyEnumName() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 8.2K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/primitives/Ints.java

       *     such index exists.
       */
      public static int indexOf(int[] array, int target) {
        return indexOf(array, target, 0, array.length);
      }
    
      // TODO(kevinb): consider making this public
      private static int indexOf(int[] array, int target, int start, int end) {
        for (int i = start; i < end; i++) {
          if (array[i] == target) {
            return i;
          }
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 16:45:58 GMT 2026
    - 31.3K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb/DfsImpl.java

                            next = next.next();
                        } while (next != dr);
    
                        if (dr.getPathConsumed() > (path != null ? path.length() : 0)) {
                            log.error("Consumed more than we provided");
                        }
    
                        link = path != null && dr.getPathConsumed() > 0 ? path.substring(0, dr.getPathConsumed()) : "\\";
                        dr.setLink(link);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 29.7K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/io/MoreFilesTest.java

       * not possible to protect against this if the file system doesn't.
       */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      public void testDirectoryDeletion_directorySymlinkRace() throws Exception {
        int iterations = isAndroid() ? 100 : 5000;
        for (DirectoryDeleteMethod method : EnumSet.allOf(DirectoryDeleteMethod.class)) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 27.5K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb1/smb1/Dfs.java

            if (ki < key.length()) {
                key = key.substring(0, ki);
            }
    
            /* Subtract the server and share from the pathConsumed so that
             * it refects the part of the relative path consumed and not
             * the entire path.
             */
            dr.pathConsumed -= 1 + server.length() + 1 + share.length();
    
            if (referrals != null && System.currentTimeMillis() + 10000 > referrals.expiration) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 14.2K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/base/internal/Finalizer.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * Thread that finalizes referents. All references should implement {@code
     * com.google.common.base.FinalizableReference}.
     *
     * <p>While this class is public, we consider it to be *internal* and not part of our published API.
     * It is public so we can access it reflectively across class loaders in secure environments.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 11 03:19:29 GMT 2026
    - 9.6K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

            }
          }
        }
      }
    
      @SuppressWarnings({
        "Interruption", // We are restoring an interrupt on this thread.
        "ThreadPriorityCheck", // TODO: b/175898629 - Consider onSpinWait.
      })
      private void waitForInterrupt(Thread currentThread) {
        /*
         * If someone called cancel(true), it is possible that the interrupted bit hasn't been set yet.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 10K bytes
    - Click Count (0)
Back to Top