- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for reentrant (0.27 sec)
-
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
if (submittingTaskQueue.thread == submitting) { sequencer = null; // Submit from inside a reentrant submit. We don't know if this one will be reentrant (and // can't know without submitting something to the executor) so queue to run iteratively. // Task must be null, since each execution on this executor can only produce one more
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 22.1K bytes - Viewed (0) -
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) -
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) -
guava/src/com/google/common/util/concurrent/Striped.java
return new CompactStriped<>(stripes, supplier); } /** * Creates a {@code Striped<Lock>} with eagerly initialized, strongly referenced locks. Every lock * is reentrant. * * @param stripes the minimum number of stripes (locks) required * @return a new {@code Striped<Lock>} */ public static Striped<Lock> lock(int stripes) { return custom(stripes, PaddedLock::new);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 20.6K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/EventBus.java
* * <p>Disadvantages of EventBus include: * * <ul> * <li>It makes the cross-references between producer and subscriber harder to find. This can * complicate debugging, lead to unintentional reentrant calls, and force apps to eagerly * initialize all possible subscribers at startup time. * <li>It uses reflection in ways that break when code is processed by optimizers/minimizers like
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 12.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
(startTime == 0L) ? timeoutNanos : remainingNanos(startTime, timeoutNanos), reentrant); threw = false; return satisfied; } finally { if (!satisfied) { try { // Don't need to signal if timed out, but do if interrupted if (threw && !reentrant) { signalNextWaiter(); } } finally { lock.unlock();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 42.8K bytes - Viewed (0) -
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) -
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) -
ci/official/containers/ml_build_arm64/builder.devtoolset/gcc9-fixups.patch
--- a/locale/xlocale.h +++ b/locale/xlocale.h @@ -20,6 +20,9 @@ #ifndef _XLOCALE_H #define _XLOCALE_H 1 +#ifndef _BITS_TYPES___LOCALE_T_H +#define _BITS_TYPES___LOCALE_T_H 1 + /* Structure for reentrant locale using functions. This is an (almost) opaque type for the user level programs. The file and this data structure is not standardized. Don't rely on it. It can @@ -41,4 +44,6 @@ typedef struct __locale_struct
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Mon Nov 11 19:25:56 UTC 2024 - 8.9K bytes - Viewed (0) -
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 Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 16.2K bytes - Viewed (0)