Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for guard (0.02 sec)

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

          guard.condition.signalAll();
        }
      }
    
      /** Records that the current thread is about to wait on the specified guard. */
      @GuardedBy("lock")
      private void beginWaitingFor(Guard guard) {
        int waiters = guard.waiterCount++;
        if (waiters == 0) {
          // push guard onto activeGuards
          guard.next = activeGuards;
          activeGuards = guard;
    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-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

      public final void testEnterWhen_initiallyTrue() throws Exception {
        TestGuard guard = new TestGuard(true);
        thread1.callAndAssertReturns(enterWhen(), guard);
      }
    
      public final void testEnterWhen_initiallyFalse() throws Exception {
        TestGuard guard = new TestGuard(false);
        thread1.callAndAssertWaits(enterWhen(), guard);
        monitor.enter();
        guard.setSatisfied(true);
        monitor.leave();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 8K bytes
    - Viewed (0)
  3. 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 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/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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 27K bytes
    - Viewed (0)
  5. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  6. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java

        Monitor monitor2 = new Monitor();
        FlagGuard guard = new FlagGuard(monitor2);
        assertThrows(IllegalMonitorStateException.class, () -> monitor1.getWaitQueueLength(guard));
      }
    
      public void testHasWaitersWithWrongMonitorThrowsIMSE() {
        Monitor monitor1 = new Monitor();
        Monitor monitor2 = new Monitor();
        FlagGuard guard = new FlagGuard(monitor2);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java

        Monitor monitor2 = new Monitor();
        FlagGuard guard = new FlagGuard(monitor2);
        assertThrows(IllegalMonitorStateException.class, () -> monitor1.getWaitQueueLength(guard));
      }
    
      public void testHasWaitersWithWrongMonitorThrowsIMSE() {
        Monitor monitor1 = new Monitor();
        Monitor monitor2 = new Monitor();
        FlagGuard guard = new FlagGuard(monitor2);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  9. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/platform/PlatformTest.kt

    import org.junit.jupiter.api.extension.RegisterExtension
    
    class PlatformTest {
      @RegisterExtension
      var platform = PlatformRule()
    
      @Test
      fun alwaysBuilds() {
        Platform()
      }
    
      /** Guard against the default value changing by accident.  */
      @Test
      fun defaultPrefix() {
        assertThat(Platform().getPrefix()).isEqualTo("OkHttp")
      }
    
      @Test
      fun testToStringIsClassname() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 1.4K bytes
    - Viewed (0)
Back to top