Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 316 for enter_1 (0.15 sec)

  1. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

       * methods that do not take an explicit timeout value, a single test case is generated only if the
       * implicit timeout of that method matches the given timeoutsToUse. For example, enter() is
       * treated like enter(MAX, MILLIS) and tryEnter() is treated like enter(0, MILLIS).
       */
      private static void addTests(
          TestSuite suite,
          Method method,
          Scenario scenario,
          TimeoutsToUse timeoutsToUse,
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

       * methods that do not take an explicit timeout value, a single test case is generated only if the
       * implicit timeout of that method matches the given timeoutsToUse. For example, enter() is
       * treated like enter(MAX, MILLIS) and tryEnter() is treated like enter(0, MILLIS).
       */
      private static void addTests(
          TestSuite suite,
          Method method,
          Scenario scenario,
          TimeoutsToUse timeoutsToUse,
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/ready.go

    func (r *ready) wait(ctx context.Context) error {
    	_, err := r.waitAndReadGeneration(ctx)
    	return err
    }
    
    // waitAndReadGenration blocks until it is Ready or Stopped and returns number
    // of times we entered ready state if Ready and error otherwise.
    func (r *ready) waitAndReadGeneration(ctx context.Context) (int, error) {
    	for {
    		// r.done() only blocks if state is Pending
    		select {
    		case <-ctx.Done():
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 16 13:32:11 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractService.java

       *
       * @since 27.0
       */
      @ForOverride
      protected void doCancelStart() {}
    
      @CanIgnoreReturnValue
      @Override
      public final Service startAsync() {
        if (monitor.enterIf(isStartable)) {
          try {
            snapshot = new StateSnapshot(STARTING);
            enqueueStartingEvent();
            doStart();
          } catch (Throwable startupFailure) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

       */
      public abstract static class Listener {
        /**
         * Called when the service initially becomes healthy.
         *
         * <p>This will be called at most once after all the services have entered the {@linkplain
         * State#RUNNING running} state. If any services fail during start up or {@linkplain
         * State#FAILED fail}/{@linkplain State#TERMINATED terminate} before all other services have
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 12:41:16 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/Service.java

     * therefore every method of the listener will be called at most once. N.B. The {@link State#FAILED}
     * and {@link State#TERMINATED} states are terminal states, once a service enters either of these
     * states it cannot ever leave them.
     *
     * <p>Implementors of this interface are strongly encouraged to extend one of the abstract classes
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 10.7K bytes
    - Viewed (0)
  7. api/maven-api-core/src/main/java/org/apache/maven/api/services/Prompter.java

     * @since 4.0.0
     */
    @Experimental
    public interface Prompter extends Service {
        /**
         * Prompts the user for a string.
         *
         * @param message the message to display to the user
         * @return the string entered by the user
         * @throws PrompterException if an exception occurs
         */
        @Nonnull
        default String prompt(@Nullable String message) throws PrompterException {
            return prompt(message, null, null);
        }
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Fri Nov 17 15:52:15 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  8. platforms/documentation/docs/src/docs/userguide/running-builds/additional/continuous_builds.adoc

    This isn't unique to continuous build.
    A task that modifies its own inputs will never be considered up-to-date when run "normally" without continuous build.
    
    If your build enters a build cycle like this, you can track down the task by looking at the list of files reported changed by Gradle.
    After identifying the file(s) that are changed during each build, you should look for a task that has that file as an input.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Feb 05 18:33:11 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/AbstractService.java

       *
       * @since 27.0
       */
      @ForOverride
      protected void doCancelStart() {}
    
      @CanIgnoreReturnValue
      @Override
      public final Service startAsync() {
        if (monitor.enterIf(isStartable)) {
          try {
            snapshot = new StateSnapshot(STARTING);
            enqueueStartingEvent();
            doStart();
          } catch (Throwable startupFailure) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/ServiceManager.java

       */
      public abstract static class Listener {
        /**
         * Called when the service initially becomes healthy.
         *
         * <p>This will be called at most once after all the services have entered the {@linkplain
         * State#RUNNING running} state. If any services fail during start up or {@linkplain
         * State#FAILED fail}/{@linkplain State#TERMINATED terminate} before all other services have
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 12:41:16 UTC 2024
    - 33K bytes
    - Viewed (0)
Back to top