- Sort Score
- Num 10 results
- Language All
Results 941 - 950 of 1,325 for concurrency (0.14 seconds)
-
src/main/java/jcifs/SmbResourceException.java
return "Release existing locks or wait for them to be released"; case BUFFER: return "Reduce buffer usage or increase buffer pool size"; case THREAD_POOL: return "Reduce concurrent operations or increase thread pool size"; default: return "Check resource availability and retry"; } } /** * Static factory for file handle exhaustion */
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 5.6K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/ConcurrencyDependencyGraph.java
import org.apache.maven.lifecycle.internal.ProjectSegment; import org.apache.maven.project.MavenProject; /** * <p> * Presents a view of the Dependency Graph that is suited for concurrent building. * </p> * <strong>NOTE:</strong> This class is not part of any public api and can be changed or deleted without prior notice. * * @since 3.0 */ public class ConcurrencyDependencyGraph {
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Jul 23 17:27:08 GMT 2025 - 5.9K bytes - Click Count (0) -
android/guava/src/com/google/common/io/CharSequenceReader.java
* such as: * * - Make checkOpen return the non-null `seq`. Then callers can assign that to a local variable or * even back to `this.seq`. However, that may suggest that we're defending against concurrent * mutation, which is not an actual risk because we use `synchronized`. * - Make `remaining` require a non-null `seq` argument. But this is a bit weird because the
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
import java.io.InterruptedIOException import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicInteger import kotlin.test.assertFailsWith import okhttp3.Headers import okhttp3.Headers.Companion.headersOf import okhttp3.TestUtil.headerEntries import okhttp3.TestUtil.repeat import okhttp3.internal.EMPTY_BYTE_ARRAY import okhttp3.internal.concurrent.Lockable
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 75.5K bytes - Click Count (0) -
.teamcity/scripts/CheckWrapper.java
* limitations under the License. */ import java.io.*; import java.nio.charset.*; import java.nio.file.*; import java.util.*; import java.util.concurrent.*; import java.util.regex.*; import java.util.stream.*; /** * TeamCity helper script to validate that each commit in a PR uses only released Gradle versions in the wrapper. *
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Jan 20 03:53:25 GMT 2026 - 6.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheCorruptionTest.kt
import java.net.CookieManager import java.net.ResponseCache import java.text.DateFormat import java.text.SimpleDateFormat import java.util.Date import java.util.Locale import java.util.TimeZone import java.util.concurrent.TimeUnit import javax.net.ssl.HostnameVerifier import javax.net.ssl.SSLSession import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import mockwebserver3.junit5.StartStop
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Jun 18 12:28:21 GMT 2025 - 6K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/CollectionAddTester.java
* what to do with <a * href="https://github.com/openjdk/jdk/blob/c25c4896ad9ef031e3cddec493aef66ff87c48a7/src/java.base/share/classes/java/util/concurrent/ConcurrentHashMap.java#L4830">{@code * ConcurrentHashMap} support for {@code entrySet().add()}</a>. */ @J2ktIncompatible @GwtIncompatible // reflection
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 6K bytes - Click Count (0) -
guava-testlib/src/com/google/common/collect/testing/testers/CollectionAddTester.java
* what to do with <a * href="https://github.com/openjdk/jdk/blob/c25c4896ad9ef031e3cddec493aef66ff87c48a7/src/java.base/share/classes/java/util/concurrent/ConcurrentHashMap.java#L4830">{@code * ConcurrentHashMap} support for {@code entrySet().add()}</a>. */ @J2ktIncompatible @GwtIncompatible // reflection
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 6K bytes - Click Count (0) -
okcurl/src/main/kotlin/okhttp3/curl/Main.kt
import com.github.ajalt.clikt.parameters.options.option import com.github.ajalt.clikt.parameters.types.int import java.security.cert.X509Certificate import java.util.Properties import java.util.concurrent.TimeUnit.SECONDS import javax.net.ssl.HostnameVerifier import javax.net.ssl.SSLSocketFactory import javax.net.ssl.TrustManager import javax.net.ssl.X509TrustManager import okhttp3.Call import okhttp3.OkHttpClient
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheControlJvmTest.kt
*/ package okhttp3 import assertk.assertThat import assertk.assertions.isEqualTo import assertk.assertions.isFalse import assertk.assertions.isSameInstanceAs import assertk.assertions.isTrue import java.util.concurrent.TimeUnit import kotlin.test.assertFailsWith import okhttp3.CacheControl.Companion.parse import okhttp3.Headers.Companion.headersOf import org.junit.jupiter.api.Test class CacheControlJvmTest { @TestCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 22:17:59 GMT 2026 - 7.4K bytes - Click Count (0)