Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for reentrant (0.07 sec)

  1. guava-tests/test/com/google/common/base/AbstractIteratorTest.java

                boolean unused = hasNext();
                throw new AssertionError();
              }
            };
        assertThrows(IllegalStateException.class, iter::hasNext);
      }
    
      // Technically we should test other reentrant scenarios (4 combinations of
      // hasNext/next), but we'll cop out for now, knowing that
      // next() both start by invoking hasNext() anyway.
    
      /** Throws an undeclared checked exception. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Sep 17 18:14:12 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/AbstractIteratorTest.java

                boolean unused = hasNext();
                throw new AssertionError();
              }
            };
        assertThrows(IllegalStateException.class, iter::hasNext);
      }
    
      // Technically we should test other reentrant scenarios (9 combinations of
      // hasNext/next/peek), but we'll cop out for now, knowing that peek() and
      // next() both start by invoking hasNext() anyway.
    
      /** Throws an undeclared checked exception. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 15 17:36:06 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/collect/AbstractIteratorTest.java

                boolean unused = hasNext();
                throw new AssertionError();
              }
            };
        assertThrows(IllegalStateException.class, iter::hasNext);
      }
    
      // Technically we should test other reentrant scenarios (9 combinations of
      // hasNext/next/peek), but we'll cop out for now, knowing that peek() and
      // next() both start by invoking hasNext() anyway.
    
      /** Throws an undeclared checked exception. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 15 17:36:06 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

      }
    
      public void testReentrancy_noDeadlock() {
        lockA.lock();
        lockB.lock();
        lockA.lock(); // Should not assert on lockB -> reentrant(lockA)
      }
    
      public void testExplicitOrdering_noViolations() {
        lock1.lock();
        lock3.lock();
        lock3.unlock();
        lock2.lock();
        lock3.lock();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

      }
    
      public void testReentrancy_noDeadlock() {
        lockA.lock();
        lockB.lock();
        lockA.lock(); // Should not assert on lockB -> reentrant(lockA)
      }
    
      public void testExplicitOrdering_noViolations() {
        lock1.lock();
        lock3.lock();
        lock3.unlock();
        lock2.lock();
        lock3.lock();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

           * class with a manual reference back to the "containing" class.)
           *
           * This has the nice-ish side effect of limiting reentrancy: run() calls
           * timeoutFuture.setException() calls run(). That reentrancy would already be harmless, since
           * timeoutFuture can be set (and delegate cancelled) only once. (And "set only once" is
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

                },
                directExecutor()));
        thingToCancel[0] = serializer.submit(Callables.returning(null), directExecutor());
        results.add(thingToCancel[0]);
        // Enqueue more than enough tasks to force reentrancy.
        for (int i = 0; i < 5; i++) {
          results.add(serializer.submit(Callables.returning(null), directExecutor()));
        }
    
        manualExecutorTask[0].run();
    
        for (Future<?> result : results) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

                },
                directExecutor()));
        thingToCancel[0] = serializer.submit(Callables.returning(null), directExecutor());
        results.add(thingToCancel[0]);
        // Enqueue more than enough tasks to force reentrancy.
        for (int i = 0; i < 5; i++) {
          results.add(serializer.submit(Callables.returning(null), directExecutor()));
        }
    
        manualExecutorTask[0].run();
    
        for (Future<?> result : results) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
Back to top