Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for reentrant (0.03 sec)

  1. 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.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectionListener.kt

     *
     * All event methods must execute fast, without external locking, cannot throw exceptions,
     * attempt to mutate the event parameters, or be reentrant back into the client.
     * Any IO - writing to files or network should be done asynchronously.
     */
    internal abstract class ConnectionListener {
      /**
       * Invoked as soon as a call causes a connection to be started.
       */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/eventbus/Dispatcher.java

              @Override
              protected Queue<Event> initialValue() {
                return new ArrayDeque<>();
              }
            };
    
        /** Per-thread dispatch state, used to avoid reentrant event dispatching. */
        @SuppressWarnings("ThreadLocalUsage") // Each Dispatcher needs its own state.
        private final ThreadLocal<Boolean> dispatching =
            new ThreadLocal<Boolean>() {
              @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

      // TODO: Test waitFor(Guard, long, TimeUnit).
      // TODO: Test getQueueLength().
      // TODO: Test hasQueuedThreads().
      // TODO: Test getWaitQueueLength(Guard).
      // TODO: Test automatic signaling before leave, waitFor, and reentrant enterWhen.
      // TODO: Test blocking to re-enter monitor after being signaled.
      // TODO: Test interrupts with both interruptible and uninterruptible monitor.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 8K bytes
    - Viewed (0)
  5. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

     * using a lock, however it is dangerous to dispatch listeners while holding a lock because they
     * might run on the {@code directExecutor()} or be otherwise re-entrant (call back into your
     * object). So it is important to not call {@link #dispatch} while holding any locks. This is why
     * {@link #enqueue} and {@link #dispatch} are 2 different methods. It is expected that the decision
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.1K bytes
    - Viewed (0)
Back to top