Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 721 - 730 of 1,325 for concurrency (0.07 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. .idea/scopes/Gradle_public_API.xml

    .*&amp;&amp;!src:*..*.internal.*&amp;&amp;!src:*..*.internal..*&amp;&amp;(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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top