- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 80 for Races (0.03 seconds)
-
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,
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Tue Aug 05 15:41:37 GMT 2025 - 26.6K bytes - Click Count (0) -
cmd/http-tracer_test.go
} if totalRequests == 0 { t.Error("Expected some total requests to be recorded, but got zero") } t.Logf("Total requests recorded: %d", totalRequests) t.Logf("Race condition test passed - no races detected") } // TestHTTPAPIStatsRaceCondition tests concurrent access to HTTPAPIStats specifically. func TestRaulHTTPAPIStatsRaceCondition(t *testing.T) { stats := &HTTPAPIStats{} const numGoroutines = 50Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
@Override protected Scheduler scheduler() { return new CustomScheduler() { @Override @SuppressWarnings("ThreadPriorityCheck") // doing our best to test for races protected Schedule getNextSchedule() throws Exception { if (state() != State.STARTING) { inGetNextSchedule.await(); Thread.yield();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 22.8K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
@Override protected Scheduler scheduler() { return new CustomScheduler() { @Override @SuppressWarnings("ThreadPriorityCheck") // doing our best to test for races protected Schedule getNextSchedule() throws Exception { if (state() != State.STARTING) { inGetNextSchedule.await(); Thread.yield();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 22.8K bytes - Click Count (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 neverCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Feb 19 21:24:11 GMT 2025 - 20.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java
Thread t = newStartedThread( new CheckedRunnable() { @Override @SuppressWarnings("ThreadPriorityCheck") // doing our best to test for races public void realRun() { while (!at.compareAndSet(2.0, 3.0)) { Thread.yield(); } } });Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 7.3K bytes - Click Count (0) -
cmd/erasure-server-pool-rebalance.go
NoAuditLog: true, }) // This can happen when rebalance stop races with ongoing rebalance workers. // These rebalance failures can be ignored. if err != nil { // This can happen when rebalance stop races with ongoing rebalance workers. // These rebalance failures can be ignored.Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 28.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java
Thread t = newStartedThread( new CheckedRunnable() { @Override @SuppressWarnings("ThreadPriorityCheck") // doing our best to test for races public void realRun() { while (!at.compareAndSet(2.0, 3.0)) { Thread.yield(); } } });Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 10.6K bytes - Click Count (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.assertLockNotHeld() taskRunner.withLock { yieldUntil() } }Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 11.9K bytes - Click Count (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.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Click Count (0)