- Sort Score
- Result 10 results
- Languages All
Results 611 - 620 of 1,082 for concurrent (1.29 sec)
-
android/guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java
import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.lang.reflect.Modifier; import java.util.ArrayList; import java.util.List; import java.util.concurrent.atomic.AtomicInteger; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /** * Tester to ensure forwarding wrapper works by delegating calls to the corresponding method with
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 9.1K bytes - Viewed (0) -
android/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 Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Oct 10 23:13:45 UTC 2025 - 17.2K bytes - Viewed (0) -
src/main/java/jcifs/util/transport/Transport.java
import java.io.InputStream; import java.net.SocketTimeoutException; import java.util.Iterator; import java.util.Map; import java.util.Map.Entry; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicLong; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.RuntimeCIFSException; import jcifs.smb.RequestParam; /**
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 27.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt
import java.net.SocketTimeoutException import java.time.Duration import java.util.Arrays import java.util.Collections import java.util.Random import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicInteger import kotlin.test.assertFailsWith import mockwebserver3.Dispatcher import mockwebserver3.MockResponse import mockwebserver3.MockWebServer
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 35.5K bytes - Viewed (0) -
mockwebserver-junit5/src/test/java/mockwebserver3/junit5/StartStopTest.kt
* limitations under the License. */ package mockwebserver3.junit5 import assertk.assertThat import assertk.assertions.isFalse import assertk.assertions.isTrue import java.util.concurrent.CopyOnWriteArrayList import mockwebserver3.Dispatcher import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import mockwebserver3.RecordedRequest import org.junit.jupiter.api.Test
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Jun 18 11:13:17 UTC 2025 - 3.3K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.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 java.util.logging.Level.SEVERE; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.annotations.VisibleForTesting;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Feb 10 21:03:40 UTC 2025 - 2.8K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/execution/DefaultMavenExecutionResult.java
* under the License. */ package org.apache.maven.execution; import java.util.Collections; import java.util.IdentityHashMap; import java.util.List; import java.util.Map; import java.util.concurrent.CopyOnWriteArrayList; import org.apache.maven.project.DependencyResolutionResult; import org.apache.maven.project.MavenProject; public class DefaultMavenExecutionResult implements MavenExecutionResult {Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 3.4K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/PluginLifecycle.java
* KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ package org.apache.maven.lifecycle.internal.concurrent; import java.util.Collection; import java.util.Collections; import java.util.List; import java.util.stream.Collectors; import java.util.stream.Stream; import org.apache.maven.api.Lifecycle;
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
import java.util.EnumMap; import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.Set; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import java.util.logging.Level; import org.jspecify.annotations.Nullable; /**
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 17:06:34 UTC 2025 - 35.9K bytes - Viewed (0) -
okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt
* limitations under the License. * */ package okhttp3.coroutines import assertk.assertThat import assertk.assertions.isEqualTo import assertk.assertions.isTrue import java.io.IOException import java.util.concurrent.TimeUnit import kotlin.test.assertFailsWith import kotlin.time.Duration.Companion.seconds import kotlinx.coroutines.CancellationException import kotlinx.coroutines.Dispatchers
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 5.3K bytes - Viewed (0)