Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 513 for Completer (0.06 sec)

  1. docs/ja/docs/deployment/server-workers.md

    [19511] [INFO] Waiting for application startup.
    [19511] [INFO] Application startup complete.
    [19513] [INFO] Started server process [19513]
    [19513] [INFO] Waiting for application startup.
    [19513] [INFO] Application startup complete.
    [19514] [INFO] Started server process [19514]
    [19514] [INFO] Waiting for application startup.
    [19514] [INFO] Application startup complete.
    [19515] [INFO] Started server process [19515]
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

        computingLatch.countDown();
        // don't check cache.size() until we know the get("b") call is complete
        computationComplete.await();
    
        // At this point, the listener should be holding the seed value (a -> a), and the map should
        // contain the computed value (b -> b), since the clear() happened before the computation
        // completed.
        assertEquals(1, listener.size());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 15:00:32 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    	// if no heal-results are consumed (via the heal-status API)
    	// for this timeout duration, the heal sequence is aborted.
    	healUnconsumedTimeout = 24 * time.Hour
    
    	// time-duration to keep heal sequence state after it
    	// completes.
    	keepHealSeqStateDuration = time.Minute * 10
    
    	// nopHeal is a no operating healing action to
    	// wait for the current healing operation to finish
    	nopHeal = ""
    )
    
    var (
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  4. doc/next/6-stdlib/99-minor/testing/36532.md

    The new [T.Context] and [B.Context] methods return a context that's canceled
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 20 17:36:54 UTC 2024
    - 141 bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

                  cacheRequestClosed = true
                  cacheRequest.abort() // Failed to write a complete cache response.
                }
                throw e
              }
    
              if (bytesRead == -1L) {
                if (!cacheRequestClosed) {
                  cacheRequestClosed = true
                  cacheBody.close() // The cache response is complete!
                }
                return -1
              }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Mar 22 07:09:21 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/Call.kt

       * exception.
       *
       * @throws IllegalStateException when the call has already been executed.
       */
      fun enqueue(responseCallback: Callback)
    
      /** Cancels the request, if possible. Requests that are already complete cannot be canceled. */
      fun cancel()
    
      /**
       * Returns true if this call has been either [executed][execute] or [enqueued][enqueue]. It is an
       * error to execute a call more than once.
       */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 3.6K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java

        this.future = future;
    
        future.addListener(this, directExecutor());
      }
    
      @Override
      public void run() {
        countDownLatch.countDown();
      }
    
      /**
       * Verify that the listener completes in a reasonable amount of time, and Asserts that the future
       * returns the expected data.
       *
       * @throws Throwable if the listener isn't called or if it resulted in a throwable or if the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:12:42 UTC 2023
    - 3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

      /**
       * Do interruptible work here - do not complete Futures here, as their listeners could be
       * interrupted.
       */
      @ParametricNullness
      abstract T runInterruptibly() throws Exception;
    
      /**
       * Any interruption that happens as a result of calling interruptTask will arrive before this
       * method is called. Complete Futures here.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/cache/CacheStats.java

       * value. This is usually incremented in conjunction with {@code missCount}, though {@code
       * missCount} is also incremented when cache loading completes successfully (see {@link
       * #loadSuccessCount}). Multiple concurrent misses for the same key will result in a single load
       * operation. This may be incremented not in conjunction with {@code missCount} if the load occurs
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  10. guava/src/com/google/common/cache/CacheStats.java

       * value. This is usually incremented in conjunction with {@code missCount}, though {@code
       * missCount} is also incremented when cache loading completes successfully (see {@link
       * #loadSuccessCount}). Multiple concurrent misses for the same key will result in a single load
       * operation. This may be incremented not in conjunction with {@code missCount} if the load occurs
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 12.6K bytes
    - Viewed (0)
Back to top