- Sort Score
- Num 10 results
- Language All
Results 821 - 830 of 1,325 for concurrency (0.07 seconds)
-
android/guava/src/com/google/common/collect/Multimaps.java
* {@code factory}, and the multimap contents are all serializable. * * <p>The multimap is not threadsafe when any concurrent operations update the multimap, even if * {@code map} and the instances generated by {@code factory} are. Concurrent read operations will * work correctly. To allow concurrent update operations, wrap the multimap with a call to {@link * #synchronizedMultimap}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 86K bytes - Click Count (0) -
guava/src/com/google/common/collect/Multimaps.java
* {@code factory}, and the multimap contents are all serializable. * * <p>The multimap is not threadsafe when any concurrent operations update the multimap, even if * {@code map} and the instances generated by {@code factory} are. Concurrent read operations will * work correctly. To allow concurrent update operations, wrap the multimap with a call to {@link * #synchronizedMultimap}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 86.3K 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) -
android/guava/src/com/google/common/graph/UndirectedMultiNetworkConnections.java
import com.google.common.collect.HashMultiset; import com.google.common.collect.ImmutableMap; import com.google.common.collect.Multiset; import com.google.errorprone.annotations.concurrent.LazyInit; import java.lang.ref.Reference; import java.lang.ref.SoftReference; import java.util.Collections; import java.util.HashMap; import java.util.Map; import java.util.Set;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 3.7K bytes - Click Count (0) -
guava/src/com/google/common/collect/JdkBackedImmutableMultiset.java
import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.primitives.Ints; import com.google.errorprone.annotations.concurrent.LazyInit; import java.util.Collection; import java.util.Map; import org.jspecify.annotations.Nullable; /** * An implementation of ImmutableMultiset backed by a JDK Map and a list of entries. Used to protect
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 17:50:58 GMT 2025 - 3.2K bytes - Click Count (0) -
build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild/testcleanup/TestFilesCleanupService.kt
import java.nio.charset.StandardCharsets import java.nio.file.Files import java.nio.file.LinkOption import java.util.concurrent.ConcurrentHashMap import java.util.stream.Collectors import java.util.zip.ZipEntry import java.util.zip.ZipOutputStream import javax.inject.Inject import kotlin.concurrent.Volatile typealias LeftoverFiles = Map<File, List<String>> class TestFilesCleanupProjectState(
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Wed Feb 11 11:05:07 GMT 2026 - 14.3K bytes - Click Count (1)