Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 1,176 for CONCURRENT (0.28 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top