Search Options

Results per page
Sort
Preferred Languages
Advance

Results 521 - 530 of 883 for Concurrent (0.1 sec)

  1. guava-testlib/src/com/google/common/collect/testing/Helpers.java

       *     the size method
       */
      public static <T extends @Nullable Object> Collection<T> misleadingSizeCollection(int delta) {
        // It would be nice to be able to return a real concurrent
        // collection like ConcurrentLinkedQueue, so that e.g. concurrent
        // iteration would work, but that would not be GWT-compatible.
        // We are not "just" inheriting from ArrayList here as this doesn't work for J2kt.
        return new AbstractList<T>() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  2. android/guava-tests/benchmark/com/google/common/cache/LoadingCacheSingleThreadBenchmark.java

    import com.google.caliper.BeforeExperiment;
    import com.google.caliper.Benchmark;
    import com.google.caliper.Param;
    import com.google.common.primitives.Ints;
    import java.util.Random;
    import java.util.concurrent.atomic.AtomicLong;
    
    /**
     * Single-threaded benchmark for {@link LoadingCache}.
     *
     * @author Charles Fry
     */
    public class LoadingCacheSingleThreadBenchmark {
      @Param({"1000", "2000"})
      int maximumSize;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 3.4K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/internal.kt

    import okhttp3.Headers
    import okhttp3.HttpUrl
    import okhttp3.MediaType
    import okhttp3.MediaType.Companion.toMediaTypeOrNull
    import okhttp3.OkHttpClient
    import okhttp3.Request
    import okhttp3.Response
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.RealConnection
    
    internal fun parseCookie(
      currentTimeMillis: Long,
      url: HttpUrl,
      setCookie: String,
    ): Cookie? = Cookie.parse(currentTimeMillis, url, setCookie)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

    import assertk.assertions.isEqualTo
    import java.io.IOException
    import java.net.Inet4Address
    import java.net.Inet6Address
    import java.net.InetAddress
    import java.net.Socket
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.TimeUnit
    import javax.net.SocketFactory
    import kotlin.test.assertFailsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.SocketPolicy.ResetStreamAtStart
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  5. guava-testlib/src/com/google/common/collect/testing/TestsForSetsInJavaUtil.java

    import java.util.Iterator;
    import java.util.LinkedHashSet;
    import java.util.NavigableSet;
    import java.util.Set;
    import java.util.SortedSet;
    import java.util.TreeSet;
    import java.util.concurrent.ConcurrentSkipListSet;
    import java.util.concurrent.CopyOnWriteArraySet;
    import junit.framework.Test;
    import junit.framework.TestSuite;
    
    /**
     * Generates a test suite covering the {@link Set} implementations in the {@link java.util} package.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  6. impl/maven-core/src/main/java/org/apache/maven/graph/FilteredProjectDependencyGraph.java

         * be {@code a -> c}.
         * <p>
         * Original code would falsely report {@code a} project as "without dependencies", basically would lose link due
         * filtering. This causes build ordering issues in concurrent builders.
         */
        private List<MavenProject> applyFilter(
                Collection<? extends MavenProject> projects, boolean transitive, boolean upstream) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt

     */
    package okhttp3.internal.http
    
    import assertk.fail
    import java.io.IOException
    import java.net.ServerSocket
    import java.net.Socket
    import java.net.SocketException
    import java.util.concurrent.TimeUnit
    import kotlin.test.assertFailsWith
    import okhttp3.DelegatingServerSocketFactory
    import okhttp3.DelegatingSocketFactory
    import okhttp3.OkHttpClient
    import okhttp3.OkHttpClientTestRule
    import okhttp3.Request
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. docs/features/events.md

        printEvent("callStart");
      }
    
      @Override public void callEnd(Call call) {
        printEvent("callEnd");
      }
    
      ...
    }
    ```
    
    We can use this listener to race a pair of concurrent HTTP requests:
    
    ```java
    Request washingtonPostRequest = new Request.Builder()
        .url("https://www.washingtonpost.com/")
        .build();
    client.newCall(washingtonPostRequest).enqueue(new Callback() {
      ...
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 7.7K bytes
    - Viewed (0)
  9. okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/DnsOverHttpsTest.kt

    import assertk.assertions.isNull
    import java.io.EOFException
    import java.io.File
    import java.io.IOException
    import java.net.InetAddress
    import java.net.UnknownHostException
    import java.util.concurrent.TimeUnit
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import okhttp3.Cache
    import okhttp3.Dns
    import okhttp3.OkHttpClient
    import okhttp3.Protocol
    import okhttp3.testing.PlatformRule
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 11K bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java

    import java.lang.reflect.AccessibleObject;
    import java.lang.reflect.InvocationTargetException;
    import java.lang.reflect.Method;
    import java.lang.reflect.Modifier;
    import java.util.List;
    import java.util.concurrent.atomic.AtomicInteger;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Tester to ensure forwarding wrapper works by delegating calls to the corresponding method with
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 9.1K bytes
    - Viewed (0)
Back to top