- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for reentrant (0.04 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) -
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-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 Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 20:58:01 UTC 2025 - 16.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
val listener: EventListener = object : EventListener() { override fun requestHeadersStart(call: Call) { try { // Cancel call from another thread to avoid reentrance. cancelLater(call, 0).join() } catch (e: InterruptedException) { throw AssertionError() } } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 146.6K bytes - Viewed (0)