Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 571 - 580 of 1,070 for concurrency (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  2. github.com/apache/maven

    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. github.com/gradle/gradle

    .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)
  4. github.com/google/guava

    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)
  5. github.com/square/okhttp

    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)
  6. github.com/elastic/elasticsearch

    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)
  7. github.com/elastic/elasticsearch

    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)
  8. github.com/square/okhttp

    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)
  9. github.com/google/guava

    guava/src/com/google/common/cache/RemovalListeners.java 

     * the License.
 */

package com.google.common.cache;

import static com.google.common.base.Preconditions.checkNotNull;

import com.google.common.annotations.GwtIncompatible;
import java.util.concurrent.Executor;

/**
 * A collection of common removal listeners.
 *
 * @author Charles Fry
 * @since 10.0
 */
@GwtIncompatible
public final class RemovalListeners {

  private RemovalListeners() {}
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  10. github.com/elastic/elasticsearch

    build-conventions/src/main/java/org/elasticsearch/gradle/internal/conventions/LicensingPlugin.java 

    import org.gradle.api.provider.Property;
import org.gradle.api.provider.Provider;
import org.gradle.api.provider.ProviderFactory;

import javax.inject.Inject;
import java.util.Map;
import java.util.concurrent.Callable;

public class LicensingPlugin implements Plugin<Project> {
    final static String ELASTIC_LICENSE_URL_PREFIX = "https://raw.githubusercontent.com/elastic/elasticsearch/";
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 2.8K bytes
    - Click Count (0)
  11. github.com/google/guava

    android/guava/src/com/google/common/util/concurrent/GwtFluentFutureCatchingSpecialization.java 

     * or implied. See the License for the specific language governing permissions and limitations under
 * the License.
 */

package com.google.common.util.concurrent;

import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.J2ktIncompatible;
import org.jspecify.annotations.Nullable;

/**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 1.4K bytes
    - Click Count (0)
Back to Top