- Sort Score
- Num 10 results
- Language All
Results 721 - 730 of 1,325 for concurrency (0.09 seconds)
-
futures/listenablefuture9999/pom.xml
<description> An empty artifact that Guava depends on to signal that it is providing ListenableFuture -- but is also available in a second "version" that contains com.google.common.util.concurrent.ListenableFuture class, without any other Guava classes. The idea is: - If users want only ListenableFuture, they depend on listenablefuture-1.0.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Oct 02 19:27:26 GMT 2025 - 2.1K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/artifact/handler/manager/LegacyArtifactHandlerManager.java
* under the License. */ package org.apache.maven.artifact.handler.manager; import javax.inject.Inject; import javax.inject.Named; import javax.inject.Singleton; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import org.apache.maven.artifact.handler.ArtifactHandler; import org.apache.maven.artifact.handler.DefaultArtifactHandler; import org.apache.maven.eventspy.AbstractEventSpy;
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jan 10 08:42:00 GMT 2025 - 2.4K bytes - Click Count (0) -
android-test/src/androidDeviceTest/java/okhttp/android/test/SingleAndroidTest.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp.android.test import java.util.concurrent.TimeUnit import kotlin.test.assertEquals import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import okhttp3.ConnectionPool import okhttp3.OkHttpClient import okhttp3.Request
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Jan 26 07:38:51 GMT 2026 - 2.1K bytes - Click Count (0) -
.idea/scopes/Gradle_public_API.xml
.*&&!src:*..*.internal.*&&!src:*..*.internal..*&&(src:org.gradle.*||src:org.gradle.api..*||src:org.gradle.authentication..*||src:org.gradle.build..*||src:org.gradle.buildinit..*||src:org.gradle.caching..*||src:org.gradle.concurrent..*||src:org.gradle.deployment..*||src:org.gradle.external.javadoc..*||src:org.gradle.ide..*||src:org.gradle.ivy..*||src:org.gradle.jvm..*||src:org.gradle.language..*||src:org.gradle.maven..*||src:org.gradle.nativeplatform..*||src:org.gradle.nor...
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Thu Jul 18 15:08:47 GMT 2024 - 1.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateDefaultAtomicHelperTest.java
* or implied. See the License for the specific language governing permissions and limitations under * the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import junit.framework.TestCase;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 1.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt
import assertk.assertions.isTrue import assertk.assertions.none import java.io.IOException import java.io.InterruptedIOException import java.net.UnknownHostException import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicBoolean import kotlin.test.assertFailsWith import okhttp3.CallEvent.CallFailed import okhttp3.CallEvent.CallStart import okhttp3.CallEvent.DispatcherQueueEnd
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 15.8K bytes - Click Count (0) -
benchmarks/src/main/java/org/elasticsearch/common/bytes/BytesArrayReadLongBenchmark.java
import org.openjdk.jmh.annotations.Scope; import org.openjdk.jmh.annotations.Setup; import org.openjdk.jmh.annotations.State; import org.openjdk.jmh.annotations.Warmup; import java.io.IOException; import java.util.concurrent.TimeUnit; @Warmup(iterations = 5) @Measurement(iterations = 7) @BenchmarkMode(Mode.AverageTime) @OutputTimeUnit(TimeUnit.MILLISECONDS) @State(Scope.Thread) @Fork(value = 1)
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Mon Apr 12 20:25:06 GMT 2021 - 2.3K bytes - Click Count (0) -
benchmarks/src/main/java/org/elasticsearch/common/bytes/PagedBytesReferenceReadLongBenchmark.java
import org.openjdk.jmh.annotations.Scope; import org.openjdk.jmh.annotations.Setup; import org.openjdk.jmh.annotations.State; import org.openjdk.jmh.annotations.Warmup; import java.io.IOException; import java.util.concurrent.TimeUnit; @Warmup(iterations = 5) @Measurement(iterations = 7) @BenchmarkMode(Mode.AverageTime) @OutputTimeUnit(TimeUnit.MILLISECONDS) @State(Scope.Thread) @Fork(value = 1)
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Mon Apr 12 20:25:06 GMT 2021 - 2.3K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/RemovalListener.java
* due to eviction resulting from timed expiration, exceeding a maximum size, or garbage collection. * * <p>An instance may be called concurrently by multiple threads to process different entries. * Implementations of this interface should avoid performing blocking calls or synchronizing on * shared resources. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/AddressPolicy.kt
* limitations under the License. */ package okhttp3.internal.connection /** * A policy for how the pool should treat a specific address. */ class AddressPolicy( /** * How many concurrent calls should be possible to make at any time. * The pool will routinely try to pre-emptively open connections to satisfy this minimum. * Connections will still be closed if they idle beyond the keep-alive but will be replaced.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jun 03 17:10:08 GMT 2025 - 1.3K bytes - Click Count (0)