- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for Races (0.14 sec)
-
doc/go_mem.html
to avoid data races. In the absence of data races, Go programs behave as if all the goroutines were multiplexed onto a single processor. This property is sometimes referred to as DRF-SC: data-race-free programs execute in a sequentially consistent manner. </p> <p> While programmers should write Go programs without data races,
HTML - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Mar 04 15:54:42 GMT 2024 - 26.6K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/KtFirAnalysisSessionProvider.kt
return KtFirAnalysisSession.createAnalysisSessionByFirResolveSession(firResolveSession, validityToken) } override fun clearCaches() { cache.clear() } /** * Note: Races cannot happen because the listener is guaranteed to be invoked in a write action. */ internal class SessionInvalidationListener(val project: Project) : LLFirSessionInvalidationListener {
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Thu Apr 18 10:43:08 GMT 2024 - 5.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
try { checkCurrentState(RUNNING); } finally { monitor.leave(); } } else { // It is possible due to races that we are currently in the expected state even though we // timed out. e.g. if we weren't event able to grab the lock within the timeout we would never
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 20.4K bytes - Viewed (0) -
docs/contribute/concurrency.md
#### Per-Connection Locks Each connection has its own lock. The connections in the pool are all in a `ConcurrentLinkedQueue`. Due to data races, iterators of this queue may return removed connections. Callers must check the connection's `noNewExchanges` property before using connections from the pool.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
yieldUntil { nanoTime >= sleepUntil } } } /** * Artificially stall until manually resumed by the test thread with [runTasks]. Use this to * simulate races in tasks that doesn't have a deterministic sequence. */ fun yield() { taskRunner.assertThreadDoesntHoldLock() taskRunner.lock.withLock { yieldUntil() } }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 12.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java
when(backingMap.get(KEY)).thenReturn(new AtomicInteger(INITIAL_COUNT)); assertThrows(IllegalArgumentException.class, () -> multiset.add(KEY, COUNT_TO_ADD)); } /** * Simulate some of the races that can happen on add. We can't easily simulate the race that * happens when an {@link AtomicInteger#compareAndSet} fails, but we can simulate the case where
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 14.2K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/Striped64.java
@CheckForNull transient volatile Cell[] cells; /** * Base value, used mainly when there is no contention, but also as a fallback during table * initialization races. Updated via CAS. */ transient volatile long base; /** Spinlock (locked via CAS) used when resizing and/or creating Cells. */ transient volatile int busy; /** Package-private default constructor */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 11.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
HandshakeCertificates.Builder() .addTrustedCertificate(rootCa.certificate) .build() client = clientTestRule.newClientBuilder() .fastFallback(false) // Avoid data races. .dns(dns) .sslSocketFactory( handshakeCertificates.sslSocketFactory(), handshakeCertificates.trustManager, ) .build() val serverHandshakeCertificates =
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 18.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
* is held in the Sync state, and the lock is released whenever the state changes to {@link * #COMPLETED}, {@link #CANCELLED}, or {@link #INTERRUPTED} * * <p>To avoid races between threads doing release and acquire, we transition to the final state * in two steps. One thread will successfully CAS from RUNNING to COMPLETING, that thread will
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed May 09 15:17:25 GMT 2018 - 13.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java
when(backingMap.get(KEY)).thenReturn(new AtomicInteger(INITIAL_COUNT)); assertThrows(IllegalArgumentException.class, () -> multiset.add(KEY, COUNT_TO_ADD)); } /** * Simulate some of the races that can happen on add. We can't easily simulate the race that * happens when an {@link AtomicInteger#compareAndSet} fails, but we can simulate the case where
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 14.2K bytes - Viewed (0)