- Sort Score
- Num 10 results
- Language All
Results 841 - 850 of 1,335 for concurrent (0.09 seconds)
-
android/guava-testlib/src/com/google/common/testing/TearDownStack.java
import static com.google.common.base.Throwables.throwIfUnchecked; import com.google.common.annotations.GwtCompatible; import com.google.common.annotations.VisibleForTesting; import com.google.errorprone.annotations.concurrent.GuardedBy; import java.util.ArrayDeque; import java.util.ArrayList; import java.util.Deque; import java.util.List; import java.util.logging.Level; import java.util.logging.Logger;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Oct 01 13:14:50 GMT 2025 - 2.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ClassPathUtil.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.base.StandardSystemProperty.JAVA_CLASS_PATH; import static com.google.common.base.StandardSystemProperty.PATH_SEPARATOR; import com.google.common.annotations.GwtIncompatible;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 2.5K bytes - Click Count (0) -
guava-testlib/src/com/google/common/testing/TearDownStack.java
import static com.google.common.base.Throwables.throwIfUnchecked; import com.google.common.annotations.GwtCompatible; import com.google.common.annotations.VisibleForTesting; import com.google.errorprone.annotations.concurrent.GuardedBy; import java.util.ArrayDeque; import java.util.ArrayList; import java.util.Deque; import java.util.List; import java.util.logging.Level; import java.util.logging.Logger;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Oct 01 13:14:50 GMT 2025 - 2.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
import okhttp3.Response import okhttp3.Route import okhttp3.internal.USER_AGENT import okhttp3.internal.canReuseConnectionFor import okhttp3.internal.closeQuietly import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.concurrent.withLock import okhttp3.internal.connection.RoutePlanner.Plan import okhttp3.internal.platform.Platform import okhttp3.internal.toHostHeader class RealRoutePlanner internal constructor(
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 12.1K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/TestsForSetsInJavaUtil.java
import java.util.HashSet; import java.util.Iterator; import java.util.LinkedHashSet; 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.Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Feb 19 21:24:11 GMT 2025 - 15K bytes - Click Count (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
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 35.5K bytes - Click Count (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
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Jun 18 11:13:17 GMT 2025 - 3.3K bytes - Click Count (1) -
android/guava/src/com/google/common/cache/RemovalCause.java
* the License. */ package com.google.common.cache; import com.google.common.annotations.GwtCompatible; import java.util.Iterator; import java.util.Map; import java.util.concurrent.ConcurrentMap; /** * The reason why a cached entry was removed. * * @author Charles Fry * @since 10.0 */ @GwtCompatible public enum RemovalCause { /**Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 2.7K bytes - Click Count (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 {Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 3.4K bytes - Click Count (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;
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 3.6K bytes - Click Count (0)