- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 440 for contention (0.08 seconds)
-
android/guava/src/com/google/common/hash/LongAdder.java
* sum that is used for purposes such as collecting statistics, not for fine-grained synchronization * control. Under low update contention, the two classes have similar characteristics. But under * high contention, expected throughput of this class is significantly higher, at the expense of * higher space consumption. * * <p>This class extends {@link Number}, but does not define methods such as {@codeCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 20 13:05:10 GMT 2025 - 5.5K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/LongAdder.java
* sum that is used for purposes such as collecting statistics, not for fine-grained synchronization * control. Under low update contention, the two classes have similar characteristics. But under * high contention, expected throughput of this class is significantly higher, at the expense of * higher space consumption. * * <p>This class extends {@link Number}, but does not define methods such as {@codeCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 5.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/suggest/SuggesterResourceLoadingTest.java
} /** * Test that both mapping and settings resources can be loaded simultaneously. * Verifies no resource contention or locking issues. */ @Test public void testResourceLoading_simultaneousAccess() throws Exception { String mappings; String settings; // Load both resourcesCreated: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Mon Nov 24 03:40:05 GMT 2025 - 9.6K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerContext.java
} /** * Session identifier for the crawling session. */ protected String sessionId; /** * Atomic counter for tracking active crawler threads without lock contention. */ protected final AtomicInteger activeThreadCount = new AtomicInteger(0); /** * Atomic counter for tracking the number of accesses made. */Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Wed Dec 31 09:07:38 GMT 2025 - 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. The connection lock is never held while doing I/O (even closing a socket) to prevent contention.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Connection.kt
*/ interface Connection { /** Returns the route used by this connection. */ fun route(): Route /** * Returns the socket that this connection is using. Returns an * [SSL socket][javax.net.ssl.SSLSocket] if this connection is HTTPS. If this is an HTTP/2 * connection the socket may be shared by multiple concurrent calls. */ fun socket(): SocketCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 4.3K bytes - Click Count (0) -
build-logic/src/main/kotlin/okhttp.jvm-conventions.gradle.kts
import org.jetbrains.kotlin.gradle.dsl.JvmTarget import org.jetbrains.kotlin.gradle.tasks.KotlinCompile import tapmoc.TapmocExtension import tapmoc.configureKotlinCompatibility plugins { id("okhttp.base-conventions") id("com.gradleup.tapmoc") } val libs = extensions.getByType<VersionCatalogsExtension>().named("libs") fun library(alias: String) = libs.findLibrary(alias).get().get().let {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Feb 09 14:40:26 GMT 2026 - 1.4K bytes - Click Count (0) -
build-logic/src/main/kotlin/okhttp.testing-conventions.gradle.kts
import org.gradle.api.tasks.testing.logging.TestExceptionFormat import org.gradle.api.artifacts.VersionCatalogsExtension import okhttp3.buildsupport.platform import okhttp3.buildsupport.testJavaVersion plugins { id("okhttp.base-conventions") } val libs = extensions.getByType<VersionCatalogsExtension>().named("libs") fun library(alias: String) = libs.findLibrary(alias).get().get().let {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Feb 07 07:16:57 GMT 2026 - 1.7K bytes - Click Count (0) -
build-logic/src/main/kotlin/okhttp.publish-conventions.gradle.kts
license { name.set("The Apache Software License, Version 2.0") url.set("https://www.apache.org/licenses/LICENSE-2.0.txt") distribution.set("repo") } } scm { connection.set("scm:git:https://github.com/square/okhttp.git") developerConnection.set("scm:git:ssh://******@****.***/square/okhttp.git") url.set("https://github.com/square/okhttp") } developers { developer {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:00:38 GMT 2026 - 2.6K bytes - Click Count (0) -
build-logic/src/main/kotlin/okhttp.quality-conventions.gradle.kts
import org.gradle.api.artifacts.VersionCatalogsExtension import org.gradle.kotlin.dsl.withType import ru.vyarus.gradle.plugin.animalsniffer.AnimalSniffer plugins { id("okhttp.base-conventions") id("checkstyle") id("ru.vyarus.animalsniffer") id("com.android.lint") id("com.diffplug.spotless") } val libs = extensions.getByType<VersionCatalogsExtension>().named("libs")Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Feb 05 09:17:33 GMT 2026 - 2.9K bytes - Click Count (0)