Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 179 for waits (0.03 seconds)

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

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

      void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException;
    
      /**
       * Waits for the {@link Service} to reach the {@linkplain State#TERMINATED terminated state}.
       *
       * @throws IllegalStateException if the service {@linkplain State#FAILED fails}.
       * @since 15.0
       */
      void awaitTerminated();
    
      /**
       * Waits for the {@link Service} to reach a terminal state (either {@link Service.State#TERMINATED
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 10.8K bytes
    - Click Count (0)
  2. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

        //
        // TODO(user): Consider scaling by number of mutator threads,
        // e.g. using Thread#activeCount()
        return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L));
      }
    
      /**
       * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
       * as necessary to try to ensure that this will happen.
       *
       * @throws RuntimeException if timed out or interrupted while waiting
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 20:19:19 GMT 2026
    - 12.3K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/Monitor.java

        try {
          return satisfied = guard.isSatisfied();
        } finally {
          if (!satisfied) {
            lock.unlock();
          }
        }
      }
    
      /**
       * Waits for the guard to be satisfied. Waits indefinitely, but may be interrupted. May be called
       * only by a thread currently occupying this monitor.
       *
       * @throws InterruptedException if interrupted while waiting
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 43.5K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

        }
        return this;
      }
    
      /**
       * Waits for the all the services to reach a terminal state. After this method returns all
       * services will either be {@linkplain Service.State#TERMINATED terminated} or {@linkplain
       * Service.State#FAILED failed}.
       */
      public void awaitStopped() {
        state.awaitStopped();
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 33.2K bytes
    - Click Count (1)
  5. internal/s3select/message.go

    	// closes `doneCh` to indicate to caller to also exit.
    	//
    	// 2. If caller (Evaluate()) has an error, it sends an error
    	// message and waits for this go-routine to quit in
    	// FinishWithError()
    	//
    	// 3. If caller is done, it waits for this go-routine to exit
    	// in Finish()
    
    	quitFlag := false
    	for !quitFlag {
    		select {
    		case data := <-writer.errCh:
    			quitFlag = true
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

      /**
       * Converts the given ThreadPoolExecutor into an ExecutorService that exits when the application
       * is complete. It does so by using daemon threads and adding a shutdown hook to wait for their
       * completion.
       *
       * <p>This method waits 120 seconds before continuing with JVM termination, even if the executor
       * has not finished its work.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 45.6K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/TestThread.java

      /**
       * Asserts that a prior call that had caused this thread to block or wait has since returned
       * normally.
       */
      public void assertPriorCallReturns(@Nullable String methodName) throws Exception {
        assertThat(getResponse(methodName).getResult()).isNull();
      }
    
      /**
       * Asserts that a prior call that had caused this thread to block or wait has since returned the
       * expected boolean value.
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  8. cmd/batch-expire.go

    	if len(toDel) > 0 {
    		select {
    		case <-ctx.Done():
    		case expireCh <- toDel:
    		}
    	}
    	xioutil.SafeClose(expireCh)
    
    	<-expireDoneCh // waits for the expire goroutine to complete
    	wk.Wait()      // waits for all expire workers to retire
    
    	ri.Complete = !failed && ri.ObjectsFailed == 0
    	ri.Failed = failed || ri.ObjectsFailed > 0
    	globalBatchJobsMetrics.save(job.ID, ri)
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Apr 22 11:16:32 GMT 2025
    - 23K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/exec/Crawler.java

                crawlingInfoHelper.putToInfoMap(key, dateFormat.format(new Date()));
            }
        }
    
        /**
         * Waits for a crawler thread to complete execution.
         * This method handles interruptions gracefully and logs when a crawler process is interrupted.
         *
         * @param crawlerThread the thread to wait for; null threads are ignored
         */
        private void joinCrawlerThread(final Thread crawlerThread) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 32.4K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

         * to confirm that it is running. If the main thread's stop() call happens
         * before it has the chance, the test will fail. To avoid this, the main
         * thread calls this method, which waits until the service has performed
         * its own "running" check.
         */
        void awaitRunChecks() throws InterruptedException {
          assertTrue(
              "Service thread hasn't finished its checks. "
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 28.7K bytes
    - Click Count (0)
Back to Top