- Sort Score
- Result 10 results
- Languages All
Results 521 - 530 of 883 for Concurrent (0.13 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)