Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for guard (0.01 sec)

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

        // (b) Waiting for the single guard to become satisfied.
        // (c) Occupying the monitor and awaiting the tearDownLatch.
        //
        // Except for (c), every thread should occupy the monitor very briefly, and every thread leaves
        // the monitor with the guard satisfied. Therefore as soon as tearDownLatch is triggered, we
        // should be able to enter the monitor, and then we set the guard to satisfied for the benefit
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 27.1K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/AbstractService.java

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

      private final Guard isStartable = new IsStartableGuard();
    
      @WeakOuter
      private final class IsStartableGuard extends Guard {
        IsStartableGuard() {
          super(AbstractService.this.monitor);
        }
    
        @Override
        public boolean isSatisfied() {
          return state() == NEW;
        }
      }
    
      private final Guard isStoppable = new IsStoppableGuard();
    
      @WeakOuter
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  4. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

       * found in any textbook.
       */
    
      /** Monitor guarding all access */
      final Monitor monitor;
    
      /** Guard for waiting takes */
      private final Monitor.Guard notEmpty;
    
      /** Guard for waiting puts */
      private final Monitor.Guard notFull;
    
      // Internal helper methods
    
      /** Circularly increment i. */
      final int inc(int i) {
        return (++i == items.length) ? 0 : i;
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/ServiceManager.java

         * which it is guaranteed that it can never become healthy.
         */
        final Monitor.Guard awaitHealthGuard = new AwaitHealthGuard();
    
        @WeakOuter
        final class AwaitHealthGuard extends Monitor.Guard {
          AwaitHealthGuard() {
            super(ServiceManagerState.this.monitor);
          }
    
          @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

         * which it is guaranteed that it can never become healthy.
         */
        final Monitor.Guard awaitHealthGuard = new AwaitHealthGuard();
    
        @WeakOuter
        final class AwaitHealthGuard extends Monitor.Guard {
          AwaitHealthGuard() {
            super(ServiceManagerState.this.monitor);
          }
    
          @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  7. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

      private static final long serialVersionUID = 5595510919245408276L;
    
      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();
            }
          };
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

            queue[0] = x;
            return 0;
          }
          int parentIndex = getParentIndex(index);
          E parentElement = elementData(parentIndex);
          if (parentIndex != 0) {
            /*
             * This is a guard for the case of the childless aunt node. Since the end of the array is
             * actually the middle of the heap, a smaller childless aunt node can become a child of x
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 18:35:44 UTC 2025
    - 33.9K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final int rankConstant = fessConfig.getRankFusionRankConstantAsInteger();
            // Guard against division by zero (should not happen due to caller checks, but defensive)
            if (searchers.length == 0) {
                logger.warn("searchWithMultipleSearchers called with empty searcher array");
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 27.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/io/Files.java

       *
       * <p>Copying is not an atomic operation - in the case of an I/O error, power loss, process
       * termination, or other problems, {@code to} may not be a complete copy of {@code from}. If you
       * need to guard against those conditions, you should employ other file-level synchronization.
       *
       * <p><b>Warning:</b> If {@code to} represents an existing file, that file will be overwritten
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 25 20:24:13 UTC 2025
    - 32.8K bytes
    - Viewed (0)
Back to top