Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 116 for waits (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

      protected CountDownLatch latch;
      protected ListenableFuture<Boolean> future;
    
      @Override
      protected void setUp() throws Exception {
    
        // Create a latch and a future that waits on the latch.
        latch = new CountDownLatch(1);
        future = createListenableFuture(Boolean.TRUE, null, latch);
      }
    
      @Override
      protected void tearDown() throws Exception {
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  2. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

      protected CountDownLatch latch;
      protected ListenableFuture<Boolean> future;
    
      @Override
      protected void setUp() throws Exception {
    
        // Create a latch and a future that waits on the latch.
        latch = new CountDownLatch(1);
        future = createListenableFuture(Boolean.TRUE, null, latch);
      }
    
      @Override
      protected void tearDown() throws Exception {
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  3. samples/slack/src/main/java/okhttp3/slack/SlackClient.java

      }
    
      /** Set the OAuth session for this client. */
      public synchronized void initOauthSession(OAuthSession session) {
        this.session = session;
        this.notifyAll();
      }
    
      /** Waits for an OAuth session for this client to be set. */
      public synchronized void awaitAccessToken(Timeout timeout) throws InterruptedIOException {
        while (session == null) {
          timeout.waitUntilNotified(this);
        }
      }
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Jan 12 03:31:36 GMT 2019
    - 3.4K bytes
    - Click Count (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/HostIntervalController.java

     * The delay is calculated based on the configured delayMillisBeforeProcessing parameter.
     * If the time since the last request to the host is less than the configured delay,
     * the thread waits until the delay has elapsed.
     * This class is thread-safe.
     * The cache automatically evicts entries after 1 hour of inactivity to prevent memory leaks.
     */
    public class HostIntervalController extends DefaultIntervalController {
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Mon Nov 24 03:59:47 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/cache/LoadingCache.java

       * necessary. No observable state associated with this cache is modified until loading completes.
       *
       * <p>If another call to {@link #get} or {@link #getUnchecked} is currently loading the value for
       * {@code key}, simply waits for that thread to finish and returns its loaded value. Note that
       * multiple threads can concurrently load values for distinct keys.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 8.3K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/core/timer/TimeoutManager.java

                    logger.debug("TimeoutManager stopped.");
                }
            }
        }
    
        /**
         * Interrupts the thread and waits for it to terminate.
         *
         * @param timeoutMillis
         *            The time to wait (in milliseconds)
         * @return <code>true</code> if the thread has terminated
         * @throws InterruptedException
         *             If interrupted while waiting
         */
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Sat May 10 01:32:17 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        assertThat(owner).isSameInstanceAs(interrupter);
    
        slowChannel.exitClose.countDown(); // release the interrupter
    
        // We need to wait for the runner to exit.  To make sure that the interrupting thread wakes it
        // back up.
        runner.join(SECONDS.toMillis(10));
      }
    
      // waits for the given thread to be blocked on the given object
      private static void awaitBlockedOnInstanceOf(Thread t, Class<?> blocker)
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  8. docs/contribute/concurrency.md

    #### Http2Stream
    
    This lock guards the internal state of each stream. As above, it is never held for blocking operations. When we need to hold an application thread to block a read, we use wait/notify on this lock. This works because the lock is released while `wait()` is waiting.
    
    #### Http2Writer
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 06 16:35:36 GMT 2022
    - 7K bytes
    - Click Count (0)
  9. internal/http/server.go

    		if atomic.LoadUint32(&srv.inShutdown) != 0 {
    			// To indicate disable keep-alive, server is shutting down.
    			w.Header().Set("Connection", "close")
    
    			// Add 1 minute retry header, incase-client wants to honor it
    			w.Header().Set(RetryAfter, "60")
    
    			w.WriteHeader(http.StatusServiceUnavailable)
    			w.Write([]byte(http.ErrServerClosed.Error()))
    			return
    		}
    
    		atomic.AddInt32(&srv.requestCount, 1)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  10. internal/config/batch/batch.go

    	config.KV{
    		Key:   ReplicationWorkersWait,
    		Value: "0ms", // No wait by default between each replication attempts.
    	},
    	config.KV{
    		Key:   KeyRotationWorkersWait,
    		Value: "0ms", // No wait by default between each key rotation attempts.
    	},
    	config.KV{
    		Key:   ExpirationWorkersWait,
    		Value: "0ms", // No wait by default between each expiration attempts.
    	},
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 4.7K bytes
    - Click Count (0)
Back to Top