Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 230 for peak (0.13 sec)

  1. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

              if (taskFuture.isDone()) {
                // Since the value of oldFuture can only ever be immediateFuture(null) or setFuture of
                // a future that eventually came from immediateFuture(null), this doesn't leak
                // throwables or completion values.
                newFuture.setFuture(oldFuture);
              } else if (outputFuture.isCancelled() && taskExecutor.trySetCancelled()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  2. docs/en/docs/fastapi-people.md

    ## Top Translation Reviewers
    
    These users are the **Top Translation Reviewers**. 🕵️
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/ResponseBody.kt

     *
     * ### The response body must be closed.
     *
     * Each response body is backed by a limited resource like a socket (live network responses) or
     * an open file (for cached responses). Failing to close the response body will leak resources and
     * may ultimately cause the application to slow down or crash.
     *
     * Both this class and [Response] implement [Closeable]. Closing a response simply
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/collect/QueuesTest.java

      }
    
      /** Checks that #drain() invocations behave correctly for a drained (empty) queue. */
      private void assertDrained(BlockingQueue<Object> q) {
        assertNull(q.peek());
        assertInterruptibleDrained(q);
        assertUninterruptibleDrained(q);
      }
    
      private void assertInterruptibleDrained(BlockingQueue<Object> q) {
        // nothing to drain, thus this should wait doing nothing
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java

        assertNotNull(sepStopwatchA.get());
        // Clear all references to the Stopwatch and wait for it to be gc'd.
        sepStopwatchA.set(null);
        GcFinalization.awaitClear(sepStopwatchRef.get());
        // Return a weak reference to the parallel ClassLoader. This is the reference that should
        // eventually become clear if there are no other references to the ClassLoader.
        return new WeakReference<ClassLoader>(sepLoader);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/Multimaps.java

    import com.google.common.collect.Maps.EntryTransformer;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    import com.google.j2objc.annotations.Weak;
    import com.google.j2objc.annotations.WeakOuter;
    import java.io.IOException;
    import java.io.ObjectInputStream;
    import java.io.ObjectOutputStream;
    import java.io.Serializable;
    import java.util.AbstractCollection;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 86.3K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/ImmutableSetMultimap.java

    import com.google.errorprone.annotations.DoNotCall;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    import com.google.j2objc.annotations.RetainedWith;
    import com.google.j2objc.annotations.Weak;
    import java.io.IOException;
    import java.io.InvalidObjectException;
    import java.io.ObjectInputStream;
    import java.io.ObjectOutputStream;
    import java.util.Collection;
    import java.util.Comparator;
    import java.util.Map;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  8. cni/pkg/repair/repaircontroller.go

    	c.pods.ShutdownHandlers()
    }
    
    func (c *Controller) Reconcile(key types.NamespacedName) error {
    	pod := c.pods.Get(key.Name, key.Namespace)
    	if pod == nil {
    		delete(c.repairedPods, key) // Ensure we do not leak
    		// Pod deleted, nothing to do
    		return nil
    	}
    	return c.ReconcilePod(pod)
    }
    
    func (c *Controller) ReconcilePod(pod *corev1.Pod) (err error) {
    	if !c.matchesFilter(pod) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Feb 10 00:31:55 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/cache/CacheBuilder.java

       */
      @GwtIncompatible // java.lang.ref.WeakReference
      @CanIgnoreReturnValue
      public CacheBuilder<K, V> weakKeys() {
        return setKeyStrength(Strength.WEAK);
      }
    
      @CanIgnoreReturnValue
      CacheBuilder<K, V> setKeyStrength(Strength strength) {
        checkState(keyStrength == null, "Key strength was already set to %s", keyStrength);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 52K bytes
    - Viewed (0)
  10. CHANGELOG.md

        for a graceful shutdown before it performs an abrupt shutdown.
    
     *  Fix: Honor `RequestBody.isOneShot()` in `MultipartBody`
    
     *  Fix in `okhttp-coroutines`: Don't leak response bodies in `executeAsync()`. We had a bug where
        we didn't call `Response.close()` if the coroutine was canceled before its response was
        returned.
    
     *  Upgrade: [Okio 3.9.0][okio_3_9_0].
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:31:39 UTC 2024
    - 21.4K bytes
    - Viewed (0)
Back to top