Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 112 for waits (0.03 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. 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)
  3. 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)
  4. 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)
  5. src/main/java/org/codelibs/fess/job/PythonJob.java

        }
    
        /**
         * Executes the Python script with the configured parameters.
         * Sets up the command list, working directory, and environment variables,
         * then starts the Python process and waits for completion.
         *
         * @throws JobProcessingException if the Python script execution fails
         */
        protected void executePython() {
            final List<String> cmdList = new ArrayList<>();
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  6. 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)
  7. 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)
  8. src/main/java/jcifs/internal/fscc/FsctlPipeWaitRequest.java

        /**
         * Constructs a pipe wait request without timeout.
         *
         * @param name the pipe name to wait for
         */
        public FsctlPipeWaitRequest(final String name) {
            this.nameBytes = name.getBytes(StandardCharsets.UTF_16LE);
            this.timeoutSpecified = false;
            this.timeout = 0;
        }
    
        /**
         * Constructs a pipe wait request with timeout.
         *
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  9. internal/ioutil/wait_pipe.go

    	})
    	return err
    }
    
    // PipeReader is similar to io.PipeReader with wait group
    type PipeReader struct {
    	*io.PipeReader
    	wait func()
    }
    
    // CloseWithError close with supplied error the reader end
    func (r *PipeReader) CloseWithError(err error) error {
    	err = r.PipeReader.CloseWithError(err)
    	r.wait()
    	return err
    }
    
    // WaitPipe implements wait-group backend io.Pipe to provide
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Apr 27 14:55:36 GMT 2023
    - 1.7K bytes
    - Click Count (0)
  10. cmd/peer-s3-server.go

    					return serr
    				}
    
    				beforeState[index] = madmin.DriveStateMissing
    				afterState[index] = madmin.DriveStateMissing
    
    				return serr
    			}
    			return nil
    		}, index)
    	}
    
    	errs := g.Wait()
    
    	// Initialize heal result info
    	res = madmin.HealResultItem{
    		Type:      madmin.HealItemBucket,
    		Bucket:    bucket,
    		DiskCount: len(localDrives),
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.2K bytes
    - Click Count (0)
Back to Top