Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for FakeOp (0.15 sec)

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

        List<Integer> callOrder = new ArrayList<>();
    
        class FakeOp implements Runnable {
          final int op;
    
          FakeOp(int op) {
            this.op = op;
          }
    
          @Override
          public void run() {
            callOrder.add(op);
          }
        }
    
        e.execute(new FakeOp(0));
        e.execute(new FakeOp(1));
        e.execute(new FakeOp(2));
        fakePool.runAll();
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

                    removeWaiter(node);
                    throw new InterruptedException();
                  }
    
                  // Otherwise re-read and check doneness. If we loop then it must have been a spurious
                  // wakeup
                  localValue = valueField;
                  if (localValue != null & notInstanceOfDelegatingToFuture(localValue)) {
                    return getDoneValue(localValue);
                  }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

                    removeWaiter(node);
                    throw new InterruptedException();
                  }
    
                  // Otherwise re-read and check doneness. If we loop then it must have been a spurious
                  // wakeup
                  localValue = valueField;
                  if (localValue != null & notInstanceOfDelegatingToFuture(localValue)) {
                    return getDoneValue(localValue);
                  }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
        waiter2.awaitWaiting(); // should eventually re-park
    
        future.set(null);
        waiter2.join();
      }
    
      public void testRemoveWaiter_polling() throws Exception {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
        waiter2.awaitWaiting(); // should eventually re-park
    
        future.set(null);
        waiter2.join();
      }
    
      public void testRemoveWaiter_polling() throws Exception {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (0)
Back to top