- Sort Score
- Num 10 results
- Language All
Results 111 - 120 of 161 for Concurrency (0.07 seconds)
-
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
public void testSizingDefaults() { LoadingCache<?, ?> cache = CacheBuilder.newBuilder().build(identityLoader()); LocalCache<?, ?> map = CacheTesting.toLocalCache(cache); assertThat(map.segments).hasLength(4); // concurrency level assertThat(map.segments[0].table.length()).isEqualTo(4); // capacity / conc level } @J2ktIncompatible @GwtIncompatible // CountDownLatch
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 25.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/cache/CacheBuilderTest.java
public void testSizingDefaults() { LoadingCache<?, ?> cache = CacheBuilder.newBuilder().build(identityLoader()); LocalCache<?, ?> map = CacheTesting.toLocalCache(cache); assertThat(map.segments).hasLength(4); // concurrency level assertThat(map.segments[0].table.length()).isEqualTo(4); // capacity / conc level } @J2ktIncompatible @GwtIncompatible // CountDownLatch
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 25.6K bytes - Click Count (0) -
guava/src/com/google/common/collect/Sets.java
return new HashSet<>(Maps.capacity(expectedSize)); } /** * Creates a thread-safe set backed by a hash map. The set is backed by a {@link * ConcurrentHashMap} instance, and thus carries the same concurrency guarantees. * * <p>Unlike {@code HashSet}, this class does NOT allow {@code null} to be used as an element. The * set is serializable. * * @return a new, empty thread-safe {@code Set}
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 83K bytes - Click Count (0) -
docs/changelogs/changelog_2x.md
misconfigured `ExecutorService` that limited the number of worker threads. If you're using `Call.enqueue()` this update should significantly improve request concurrency. * **Fix: Lazily initialize the response cache.** This avoids strict mode warnings when initializing OkHttp on Android‘s main thread. * **Fix: Disable ALPN on Android 4.4.** That release of the feature wasCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 26.6K bytes - Click Count (0) -
docs/tr/docs/async.md
# Eşzamanlılık ve async / await { #concurrency-and-async-await } *path operasyon fonksiyonları* için `async def` sözdizimi hakkında detaylar ve asenkron kod, eşzamanlılık (concurrency) ve paralellik üzerine arka plan bilgisi. ## Aceleniz mi var? { #in-a-hurry } <abbr title="too long; didn't read - çok uzun; okumadım"><strong>TL;DR:</strong></abbr> Eğer `await` ile çağırmanız gerektiğini söyleyen üçüncü taraf kütüphaneler kullanıyorsanız, örneğin:Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 07:53:17 GMT 2026 - 23.7K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
int takeIndex; /** items index for next put, offer, or add. */ int putIndex; /** Number of items in the queue */ private int count; /* * Concurrency control uses the classic two-condition algorithm * found in any textbook. */ /** Monitor guarding all access */ final Monitor monitor; /** Guard for waiting takes */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 22.4K bytes - Click Count (0) -
cmd/perf-tests.go
Region: region, }) if err != nil { return res, err } } var mu sync.Mutex var uploadTimes madmin.TimeDurations wg.Add(opts.concurrency) for i := 0; i < opts.concurrency; i++ { go func(i int) { defer wg.Done() for { t := time.Now() reader := newRandomReader(opts.objectSize)Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 11.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
String error = errorMessage.get(); assertWithMessage(error).that(error).isNull(); } executor.shutdown(); } /** * He did the bash, he did the future bash The future bash, it was a concurrency smash He did the * bash, it caught on in a flash He did the bash, he did the future bash */ public void testFutureBash() { if (isWindows()) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 45.2K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/Smb2SigningDigestTest.java
} } assertTrue(hasNonZero, "Each array should have a signature"); } } @Test @DisplayName("Should handle high concurrency without deadlock") void testHighConcurrencyNoDeadlock() throws InterruptedException { int threadCount = 100; int operationsPerThread = 50;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 43.7K bytes - Click Count (0) -
docs/fr/docs/async.md
### Concurrence et Burgers { #concurrency-and-burgers } L'idée de code **asynchrone** décrite ci-dessus est parfois aussi appelée **« concurrence »**. Ce qui est différent du **« parallélisme »**. La **concurrence** et le **parallélisme** sont tous deux liés à l'idée de « différentes choses arrivant plus ou moins au même moment ».Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 27.3K bytes - Click Count (0)