- Sort Score
- Result 10 results
- Languages All
Results 421 - 430 of 967 for CONCURRENT (0.82 sec)
-
guava/src/com/google/common/hash/BloomFilterStrategies.java
import com.google.common.math.LongMath; import com.google.common.primitives.Ints; import com.google.common.primitives.Longs; import java.math.RoundingMode; import java.util.Arrays; import java.util.concurrent.atomic.AtomicLongArray; import java.util.concurrent.atomic.LongAdder; import org.jspecify.annotations.Nullable; /** * Collections of strategies of generating the k * log(M) bits required for an element to be mapped
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Jan 08 14:27:16 UTC 2025 - 10.7K bytes - Viewed (0) -
mockwebserver-junit4/src/test/java/mockwebserver3/junit4/MockWebServerRuleTest.kt
* limitations under the License. */ package mockwebserver3.junit4 import assertk.assertThat import assertk.assertions.isTrue import java.net.ConnectException import java.util.concurrent.atomic.AtomicBoolean import org.junit.Assert.fail import org.junit.Test import org.junit.runner.Description import org.junit.runners.model.Statement class MockWebServerRuleTest {Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt
* limitations under the License. */ package okhttp3 import java.io.Closeable import java.io.IOException import java.util.concurrent.LinkedBlockingDeque import okhttp3.internal.concurrent.TaskFaker import okhttp3.internal.connection.RealConnection import okhttp3.internal.connection.RoutePlanner import okhttp3.internal.connection.RoutePlanner.ConnectResult class FakeRoutePlanner(
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Oct 07 21:55:03 UTC 2025 - 6.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt
import assertk.assertions.isEqualTo import assertk.assertions.isNotEmpty import assertk.assertions.isNotNull import java.io.IOException import java.net.InetAddress import java.util.concurrent.CompletableFuture import java.util.concurrent.TimeUnit.SECONDS import javax.net.ssl.SNIHostName import javax.net.ssl.SNIMatcher import javax.net.ssl.SNIServerName import javax.net.ssl.SSLSocket import javax.net.ssl.StandardConstants
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Nov 01 12:18:11 UTC 2025 - 7.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/CollectionFuture.java
* the License. */ package com.google.common.util.concurrent; import static com.google.common.collect.Lists.newArrayListWithCapacity; import static java.util.Collections.unmodifiableList; import com.google.common.annotations.GwtCompatible; import com.google.common.collect.ImmutableCollection; import com.google.common.collect.Lists; import com.google.errorprone.annotations.concurrent.LazyInit;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 3.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java
*/ package jcifs.internal.smb2.multichannel; import java.util.ArrayList; import java.util.Collection; import java.util.List; import java.util.concurrent.ThreadLocalRandom; import java.util.concurrent.atomic.AtomicInteger; import jcifs.internal.CommonServerMessageBlock; import jcifs.internal.smb2.ServerMessageBlock2Request; import jcifs.internal.smb2.info.Smb2QueryDirectoryRequest;
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 8.2K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/graph/FilteredProjectDependencyGraph.java
package org.apache.maven.graph; import java.util.ArrayList; import java.util.Collection; import java.util.IdentityHashMap; import java.util.List; import java.util.Map; import java.util.Objects; import java.util.concurrent.ConcurrentHashMap; import org.apache.maven.execution.ProjectDependencyGraph; import org.apache.maven.project.MavenProject; /** * Provides a sub view of another dependency graph. * */
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Jun 19 16:34:39 UTC 2025 - 6.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* the License. */ package com.google.common.util.concurrent; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.errorprone.annotations.CanIgnoreReturnValue; import com.google.errorprone.annotations.DoNotMock; import java.util.concurrent.Executor; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; /**
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 10.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/package-info.java
* * <p>This package is a part of the open-source <a href="https://github.com/google/guava">Guava</a> * library. */ @CheckReturnValue @NullMarked package com.google.common.util.concurrent; import com.google.errorprone.annotations.CheckReturnValue;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 14:50:24 UTC 2024 - 1.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/ConcurrentMapPutIfAbsentTester.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.Map.Entry; import java.util.concurrent.ConcurrentMap; import org.jspecify.annotations.NullMarked; import org.junit.Ignore; /** * A generic JUnit test which tests {@code putIfAbsent} operations on a concurrent map. Can't be * invoked directly; please see {@link * com.google.common.collect.testing.ConcurrentMapTestSuiteBuilder}. *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 14:50:24 UTC 2024 - 4.9K bytes - Viewed (0)