Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for isSatisfied (0.22 sec)

  1. guava/src/com/google/common/util/concurrent/Monitor.java

       *
       * @param isSatisfied the new guard's boolean condition (see {@link Guard#isSatisfied
       *     isSatisfied()})
       * @since 21.0 (but only since 33.4.0 in the Android flavor)
       */
      public Guard newGuard(BooleanSupplier isSatisfied) {
        checkNotNull(isSatisfied, "isSatisfied");
        return new Guard(this) {
          @Override
          public boolean isSatisfied() {
            return isSatisfied.getAsBoolean();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractService.java

        }
    
        @Override
        public boolean isSatisfied() {
          return state() == NEW;
        }
      }
    
      private final Guard isStoppable = new IsStoppableGuard();
    
      @WeakOuter
      private final class IsStoppableGuard extends Guard {
        IsStoppableGuard() {
          super(AbstractService.this.monitor);
        }
    
        @Override
        public boolean isSatisfied() {
          return state().compareTo(RUNNING) <= 0;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/AbstractService.java

        }
    
        @Override
        public boolean isSatisfied() {
          return state() == NEW;
        }
      }
    
      private final Guard isStoppable = new IsStoppableGuard();
    
      @WeakOuter
      private final class IsStoppableGuard extends Guard {
        IsStoppableGuard() {
          super(AbstractService.this.monitor);
        }
    
        @Override
        public boolean isSatisfied() {
          return state().compareTo(RUNNING) <= 0;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

        private volatile boolean satisfied;
    
        public TestGuard(boolean satisfied) {
          super(MonitorTestCase.this.monitor);
          this.satisfied = satisfied;
        }
    
        @Override
        public boolean isSatisfied() {
          return this.satisfied;
        }
    
        public void setSatisfied(boolean satisfied) {
          this.satisfied = satisfied;
        }
      }
    
      private final boolean interruptible;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 8K bytes
    - Viewed (0)
  5. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

        notEmpty =
            new Monitor.Guard(monitor) {
              @Override
              public boolean isSatisfied() {
                return count > 0;
              }
            };
        notFull =
            new Monitor.Guard(monitor) {
              @Override
              public boolean isSatisfied() {
                return count < items.length;
              }
            };
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

          AwaitHealthGuard() {
            super(ServiceManagerState.this.monitor);
          }
    
          @Override
          @GuardedBy("ServiceManagerState.this.monitor")
          public boolean isSatisfied() {
            // All services have started or some service has terminated/failed.
            return states.count(RUNNING) == numberOfServices
                || states.contains(STOPPING)
                || states.contains(TERMINATED)
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      static class FlagGuard extends Monitor.Guard {
    
        private boolean satisfied;
    
        protected FlagGuard(Monitor monitor) {
          super(monitor);
        }
    
        @Override
        public boolean isSatisfied() {
          return satisfied;
        }
    
        public void setSatisfied(boolean satisfied) {
          this.satisfied = satisfied;
        }
      }
    
      private final Method method;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 27K bytes
    - Viewed (0)
  8. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

      final PriorityQueue<E> q;
      final Monitor monitor = new Monitor(true);
      private final Monitor.Guard notEmpty =
          new Monitor.Guard(monitor) {
            @Override
            public boolean isSatisfied() {
              return !q.isEmpty();
            }
          };
    
      /**
       * Creates a {@code MonitorBasedPriorityBlockingQueue} with the default initial capacity (11) that
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/authenticator/JavaNetAuthenticator.kt

              )
            return request
              .newBuilder()
              .header(credentialHeader, credential)
              .build()
          }
        }
    
        return null // No challenges were satisfied!
      }
    
      @Throws(IOException::class)
      private fun Proxy.connectToInetAddress(
        url: HttpUrl,
        dns: Dns,
      ): InetAddress =
        when (type()) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/CacheControl.kt

    import okhttp3.internal.commonToString
    
    /**
     * A Cache-Control header with cache directives from a server or client. These directives set policy
     * on what responses can be stored, and which requests can be satisfied by those stored responses.
     *
     * See [RFC 7234, 5.2](https://tools.ietf.org/html/rfc7234#section-5.2).
     */
    class CacheControl internal constructor(
      /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 10K bytes
    - Viewed (0)
Back to top