Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for waitJob (0.46 sec)

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

        thread1.callAndAssertReturns(waitFor(), guard);
      }
    
      public final void testWaitFor_initiallyFalse() throws Exception {
        TestGuard guard = new TestGuard(false);
        thread1.callAndAssertReturns(enter());
        thread1.callAndAssertWaits(waitFor(), guard);
        monitor.enter();
        guard.setSatisfied(true);
        monitor.leave();
        thread1.assertPriorCallReturns(waitFor());
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Monitor.java

       * only by a thread currently occupying this monitor.
       *
       * @throws InterruptedException if interrupted while waiting
       */
      public void waitFor(Guard guard) throws InterruptedException {
        if (!((guard.monitor == this) && lock.isHeldByCurrentThread())) {
          throw new IllegalMonitorStateException();
        }
        if (!guard.isSatisfied()) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Dec 04 18:22:01 GMT 2023
    - 38.6K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

        thread1.callAndAssertReturns(waitFor(), guard);
      }
    
      public final void testWaitFor_initiallyFalse() throws Exception {
        TestGuard guard = new TestGuard(false);
        thread1.callAndAssertReturns(enter());
        thread1.callAndAssertWaits(waitFor(), guard);
        monitor.enter();
        guard.setSatisfied(true);
        monitor.leave();
        thread1.assertPriorCallReturns(waitFor());
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

        @SuppressWarnings("unchecked") // proxy for a generic class
        <V> Callable<V> waitFor(Callable<V> callable) {
          return waitFor(callable, Callable.class);
        }
    
        @SuppressWarnings("unchecked") // proxy for a generic class
        <V> ClosingCallable<V> waitFor(ClosingCallable<V> closingCallable) {
          return waitFor(closingCallable, ClosingCallable.class);
        }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  5. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

      }
    
      /** Constructs a listenable future with a value available after the latch has counted down. */
      protected abstract <V> ListenableFuture<V> createListenableFuture(
          V value, @Nullable Exception except, CountDownLatch waitOn);
    
      /** Tests that the {@link Future#get()} method blocks until a value is available. */
      public void testGetBlocksUntilValueAvailable() throws Throwable {
    
        assertFalse(future.isDone());
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 18:30:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      }
    
      /** Identifies all waitForXxx methods, which must be called while occupying the monitor. */
      private static boolean isWaitFor(Method method) {
        return method.getName().startsWith("waitFor");
      }
    
      /** Determines whether the given method takes a Guard as its first parameter. */
      private static boolean isGuarded(Method method) {
        Class<?>[] parameterTypes = method.getParameterTypes();
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Apr 17 14:48:57 GMT 2023
    - 27.4K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

        @SuppressWarnings("unchecked") // proxy for a generic class
        <V> Callable<V> waitFor(Callable<V> callable) {
          return waitFor(callable, Callable.class);
        }
    
        @SuppressWarnings("unchecked") // proxy for a generic class
        <V> ClosingCallable<V> waitFor(ClosingCallable<V> closingCallable) {
          return waitFor(closingCallable, ClosingCallable.class);
        }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 74.7K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      }
    
      /** Identifies all waitForXxx methods, which must be called while occupying the monitor. */
      private static boolean isWaitFor(Method method) {
        return method.getName().startsWith("waitFor");
      }
    
      /** Determines whether the given method takes a Guard as its first parameter. */
      private static boolean isGuarded(Method method) {
        Class<?>[] parameterTypes = method.getParameterTypes();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 17 14:48:57 GMT 2023
    - 26.1K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

      }
    
      /** Constructs a listenable future with a value available after the latch has counted down. */
      protected abstract <V> ListenableFuture<V> createListenableFuture(
          V value, @Nullable Exception except, CountDownLatch waitOn);
    
      /** Tests that the {@link Future#get()} method blocks until a value is available. */
      public void testGetBlocksUntilValueAvailable() throws Throwable {
    
        assertFalse(future.isDone());
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 18:30:30 GMT 2023
    - 6K bytes
    - Viewed (0)
Back to top