- Sort Score
- Num 10 results
- Language All
Results 121 - 130 of 1,176 for CONCURRENT (0.28 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/Tags.kt
*/ package okhttp3.internal import java.util.concurrent.atomic.AtomicReference import kotlin.reflect.KClass /** * An immutable collection of key-value pairs implemented as a singly-linked list. * * Build up a collection by starting with [EmptyTags] and repeatedly calling [plus]. Each such call * returns a new instance. * * This collection is optimized for safe concurrent access over a very small number of elements. *
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 3.9K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/lock/Smb2Lock.java
* SMB2 Lock requests for byte-range locking. * * @author mbechler */ public class Smb2Lock implements Encodable { /** * Flag indicating a shared lock that allows concurrent read access. */ public static final int SMB2_LOCKFLAG_SHARED_LOCK = 0x1; /** * Flag indicating an exclusive lock that prevents any other access. */Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 2.8K bytes - Click Count (0) -
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}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 14:50:24 GMT 2024 - 4.9K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/ConcurrentMapReplaceEntryTester.java
import com.google.common.collect.testing.features.MapFeature; import java.util.concurrent.ConcurrentMap; import org.jspecify.annotations.NullMarked; import org.junit.Ignore; /** * A generic JUnit test which tests {@code replace(K, V, V)} operations on a concurrent map. Can't * be invoked directly; please see {@link * com.google.common.collect.testing.ConcurrentMapTestSuiteBuilder}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 14:50:24 GMT 2024 - 5.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
import java.time.Duration; import java.util.concurrent.BlockingQueue; import java.util.concurrent.CancellationException; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import java.util.concurrent.Semaphore; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 23:24:32 GMT 2026 - 22.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/cache/LocalCacheMapComputeTest.java
import static com.google.common.truth.Truth.assertThat; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static org.junit.Assert.assertThrows; import com.google.common.util.concurrent.UncheckedExecutionException; import java.util.ArrayList; import java.util.List; import java.util.Queue; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ExecutionException; import java.util.function.IntConsumer;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 6.4K bytes - Click Count (0) -
okhttp-tls/api/okhttp-tls.api
public final fun certificateAuthority (I)Lokhttp3/tls/HeldCertificate$Builder; public final fun commonName (Ljava/lang/String;)Lokhttp3/tls/HeldCertificate$Builder; public final fun duration (JLjava/util/concurrent/TimeUnit;)Lokhttp3/tls/HeldCertificate$Builder; public final fun ecdsa256 ()Lokhttp3/tls/HeldCertificate$Builder; public final fun keyPair (Ljava/security/KeyPair;)Lokhttp3/tls/HeldCertificate$Builder;
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Feb 26 19:17:33 GMT 2022 - 3.7K bytes - Click Count (0) -
src/test/java/jcifs/smb/SmbTransportPoolImplTest.java
// Use reflection to access concurrent collections Field connectionsField = SmbTransportPoolImpl.class.getDeclaredField("connections"); connectionsField.setAccessible(true); @SuppressWarnings("unchecked") java.util.concurrent.ConcurrentLinkedQueue<SmbTransportImpl> connections = (java.util.concurrent.ConcurrentLinkedQueue<SmbTransportImpl>) connectionsField.get(pool);Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 19.2K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/LinkedHashMultimap.java
* * <p>Keys and values may be null. All optional multimap methods are supported, and all returned * views are modifiable. * * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent * read operations will work correctly. To allow concurrent update operations, wrap your multimap * with a call to {@link Multimaps#synchronizedSetMultimap}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 26 20:08:09 GMT 2025 - 19.2K bytes - Click Count (0) -
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)