Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 36 for guard (0.04 seconds)

  1. android/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;
    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)
  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();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

        TestGuard guard = new TestGuard(true);
        thread1.callAndAssertReturns(true, enterIf(), guard);
        thread2.callAndAssertBlocks(enter());
      }
    
      public final void testEnterIf_initiallyFalse() throws Exception {
        TestGuard guard = new TestGuard(false);
        thread1.callAndAssertReturns(false, enterIf(), guard);
        thread2.callAndAssertReturns(enter());
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.2K bytes
    - Click Count (0)
  4. 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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.7K bytes
    - Click Count (0)
  5. 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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.7K bytes
    - Click Count (0)
  6. 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);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 5K bytes
    - Click Count (0)
  7. 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);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 5K bytes
    - Click Count (0)
  8. 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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  9. src/test/java/jcifs/smb/WinErrorTest.java

            assertEquals(WinError.WINERR_CODES.length, WinError.WINERR_MESSAGES.length, "Codes/messages length mismatch");
    
            // Exact content check to guard against accidental reordering or drift
            assertArrayEquals(
                    new int[] { WinError.ERROR_SUCCESS, WinError.ERROR_ACCESS_DENIED, WinError.ERROR_REQ_NOT_ACCEP, WinError.ERROR_BAD_PIPE,
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8.4K bytes
    - Click Count (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() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 1.4K bytes
    - Click Count (0)
Back to Top