Search Options

Results per page
Sort
Preferred Languages
Advance

Results 571 - 580 of 658 for crawler (0.04 sec)

  1. guava/src/com/google/common/util/concurrent/Monitor.java

          if (isSatisfied(guard)) {
            guard.condition.signal();
            break;
          }
        }
      }
    
      /**
       * Exactly like signalNextWaiter, but caller guarantees that guardToSkip need not be considered,
       * because caller has previously checked that guardToSkip.isSatisfied() returned false. An
       * optimization for the case that guardToSkip.isSatisfied() may be expensive.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

      // These properties are guarded by `this`.
    
      /**
       * If true, no new exchanges can be created on this connection. It is necessary to set this to
       * true when removing a connection from the pool; otherwise a racing caller might get it from the
       * pool when it shouldn't. Symmetrically, this must always be checked before returning a
       * connection from the pool.
       *
       * Once true this is always true. Guarded by this.
       */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/Futures.java

      //    visible to done(). This is because there is no happens before edge between the write and a
      //    (hypothetical) unsafe read by our caller. Note: adding 'volatile' does not fix this issue,
      //    it would just add an edge such that if done() observed non-null, then it would also
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

      }
    
      /**
       * Loads {@link WillBeUnloadedException} in a separate {@code ClassLoader}, calls {@code
       * getChecked(future, WillBeUnloadedException.class)}, and returns the loader. The caller can then
       * test that the {@code ClassLoader} can still be GCed. The test amounts to a test that {@code
       * getChecked} holds no strong references to the class.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/hash/HashCode.java

       * most-significant bytes.
       *
       * @since 14.0 (since 11.0 as {@code Hashing.padToLong(HashCode)})
       */
      public abstract long padToLong();
    
      /**
       * Returns the value of this hash code as a byte array. The caller may modify the byte array;
       * changes to it will <i>not</i> be reflected in this {@code HashCode} object or any other arrays
       * returned by this method.
       */
      // TODO(user): consider ByteString here, when that is available
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/cache/PopulatedCachesTest.java

        return warmUp(cache, WARMUP_MIN, WARMUP_MAX);
      }
    
      /**
       * Returns the entries that were added to the map, so they won't fall out of a map with weak or
       * soft references until the caller drops the reference to the returned entries.
       */
      private List<Entry<Object, Object>> warmUp(
          LoadingCache<Object, Object> cache, int minimum, int maximum) {
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  7. cmd/local-locker.go

    		if !ok {
    			// No more resources for UID, but we did update at least one.
    			return true, nil
    		}
    	}
    }
    
    // Similar to removeEntry but only removes an entry only if the lock entry exists in map.
    // Caller must hold 'l.mutex' lock.
    func (l *localLocker) expireOldLocks(interval time.Duration) {
    	defer l.getMutex()()
    
    	var readers, writers int32
    	for k, lris := range l.lockMap {
    		modified := false
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  8. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

       * in no particular order.
       *
       * <p>The returned array will be "safe" in that no references to it are maintained by this queue.
       * (In other words, this method must allocate a new array). The caller is thus free to modify the
       * returned array.
       *
       * <p>This method acts as bridge between array-based and collection-based APIs.
       *
       * @return an array containing all of the elements in this queue
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  9. cmd/bucket-metadata-sys.go

    		return errInvalidArgument
    	}
    
    	if err := meta.Save(ctx, objAPI); err != nil {
    		return err
    	}
    
    	sys.Set(meta.Name, meta)
    	globalNotificationSys.LoadBucketMetadata(bgContext(ctx), meta.Name) // Do not use caller context here
    	return nil
    }
    
    // Delete delete the bucket metadata for the specified bucket.
    // must be used by all callers instead of using Update() with nil configData.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  10. api/go1.8.txt

    pkg math/rand, type Source64 interface, Seed(int64)
    pkg math/rand, type Source64 interface, Uint64() uint64
    pkg net/http, const TrailerPrefix ideal-string
    pkg net/http, const TrailerPrefix = "Trailer:"
    pkg net/http/httptrace, type ClientTrace struct, TLSHandshakeDone func(tls.ConnectionState, error)
    pkg net/http/httptrace, type ClientTrace struct, TLSHandshakeStart func()
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Dec 21 05:25:57 UTC 2016
    - 16.3K bytes
    - Viewed (0)
Back to top