- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 75 for ConcurrentMap (0.07 seconds)
-
guava-testlib/src/com/google/common/testing/FreshValueGenerator.java
return ImmutableMap.of(key, value); } @Empty static <K, V> ConcurrentMap<K, V> generateConcurrentMap() { return Maps.newConcurrentMap(); } @Generates static <K, V> ConcurrentMap<K, V> generateConcurrentMap(K key, V value) { ConcurrentMap<K, V> map = Maps.newConcurrentMap(); map.put(key, value); return map; } @Generates
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 16:45:58 GMT 2026 - 28.7K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AtomicLongMap.java
} /* * ConcurrentMap operations which we may eventually add. * * The problem with these is that remove(K, long) has to be done in two phases by definition --- * first decrementing to zero, and then removing. putIfAbsent or replace could observe the * intermediate zero-state. Ways we could deal with this are: * * - Don't define any of the ConcurrentMap operations. This is the current state of affairs.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed May 14 13:21:19 GMT 2025 - 14K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java
*/ package jcifs.internal.smb2.multichannel; import java.io.IOException; import java.util.List; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.SmbTransport;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 11.6K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/AbstractCache.java
import com.google.common.collect.ImmutableMap; import java.util.LinkedHashMap; import java.util.Map; import java.util.Map.Entry; import java.util.concurrent.Callable; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ExecutionException; /** * This class provides a skeletal implementation of the {@code Cache} interface to minimize the * effort required to implement this interface. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 9.1K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/testing/FreshValueGenerator.java
return ImmutableMap.of(key, value); } @Empty static <K, V> ConcurrentMap<K, V> generateConcurrentMap() { return Maps.newConcurrentMap(); } @Generates static <K, V> ConcurrentMap<K, V> generateConcurrentMap(K key, V value) { ConcurrentMap<K, V> map = Maps.newConcurrentMap(); map.put(key, value); return map; } @Generates
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 16:45:58 GMT 2026 - 28.1K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/LoadingCache.java
import com.google.common.util.concurrent.ExecutionError; import com.google.common.util.concurrent.UncheckedExecutionException; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ExecutionException; /** * A semi-persistent mapping from keys to values. Values are automatically loaded by the cache, and
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 8.5K bytes - Click Count (0) -
src/main/java/jcifs/smb/PreauthIntegrityService.java
import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import java.security.SecureRandom; import java.util.Arrays; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.CIFSException; import jcifs.internal.smb2.nego.PreauthIntegrityNegotiateContext; /**
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 12.1K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
import java.util.SortedSet; import java.util.UUID; import java.util.concurrent.BlockingDeque; import java.util.concurrent.BlockingQueue; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ConcurrentNavigableMap; import java.util.concurrent.ConcurrentSkipListMap; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 17:50:58 GMT 2025 - 20.9K bytes - Click Count (0) -
android/guava/src/com/google/common/eventbus/SubscriberRegistry.java
import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.Objects; import java.util.Set; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.CopyOnWriteArraySet; import org.jspecify.annotations.Nullable; /** * Registry of subscribers to a single event bus. * * @author Colin Decker */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Jul 08 18:32:10 GMT 2025 - 10.8K bytes - Click Count (0) -
guava/src/com/google/common/cache/AbstractCache.java
import com.google.common.collect.ImmutableMap; import java.util.LinkedHashMap; import java.util.Map; import java.util.Map.Entry; import java.util.concurrent.Callable; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ExecutionException; /** * This class provides a skeletal implementation of the {@code Cache} interface to minimize the * effort required to implement this interface. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 9.2K bytes - Click Count (0)