Search Options

Results per page
Sort
Preferred Languages
Advance

Results 781 - 790 of 892 for Concurrent (0.09 sec)

  1. src/test/java/jcifs/smb/SmbTransportImplTest.java

    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verify;
    import static org.mockito.Mockito.when;
    
    import java.lang.reflect.Field;
    import java.net.Socket;
    import java.util.concurrent.atomic.AtomicLong;
    
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Nested;
    import org.junit.jupiter.api.Test;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 17.6K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/AbstractBiMap.java

    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    import com.google.j2objc.annotations.RetainedWith;
    import com.google.j2objc.annotations.WeakOuter;
    import java.io.IOException;
    import java.io.ObjectInputStream;
    import java.io.ObjectOutputStream;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 15:50:50 UTC 2025
    - 14.3K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

    import java.io.IOException
    import java.net.UnknownServiceException
    import kotlin.test.assertFailsWith
    import okhttp3.FakeRoutePlanner
    import okhttp3.FakeRoutePlanner.ConnectState.TLS_CONNECTED
    import okhttp3.internal.concurrent.TaskFaker
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.Test
    
    /**
     * Unit test for [FastFallbackExchangeFinder] implementation details.
     *
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  4. guava/src/com/google/common/base/Suppliers.java

    import com.google.common.annotations.VisibleForTesting;
    import java.io.IOException;
    import java.io.ObjectInputStream;
    import java.io.Serializable;
    import java.time.Duration;
    import java.util.Objects;
    import java.util.concurrent.TimeUnit;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Useful suppliers.
     *
     * <p>All methods return serializable suppliers as long as they're given serializable parameters.
     *
     * @author Laurence Gonsalves
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/crypto/CachedCipher.java

    import java.io.UnsupportedEncodingException;
    import java.security.InvalidKeyException;
    import java.security.Key;
    import java.security.NoSuchAlgorithmException;
    import java.util.Queue;
    import java.util.concurrent.ConcurrentLinkedQueue;
    
    import javax.crypto.BadPaddingException;
    import javax.crypto.Cipher;
    import javax.crypto.IllegalBlockSizeException;
    import javax.crypto.NoSuchPaddingException;
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Sat Nov 22 11:21:59 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  6. src/test/java/jcifs/internal/dfs/DfsReferralRequestBufferTest.java

                    int bytesEncoded = buffer.encode(dst, 0);
                    assertEquals(buffer.size(), bytesEncoded);
                }
            }
    
            @Test
            @DisplayName("Should handle concurrent size calculations")
            void testConcurrentSizeCalculations() throws InterruptedException {
                String path = "\\\\server\\share\\test";
                buffer = new DfsReferralRequestBuffer(path, 3);
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  7. src/test/java/jcifs/internal/smb1/trans2/Trans2QueryFSInformationTest.java

            trans2QueryFSInfo = new Trans2QueryFSInformation(mockConfig, FileSystemInformation.SMB_INFO_ALLOCATION);
    
            assertNotNull(trans2QueryFSInfo);
        }
    
        @Test
        @DisplayName("Test concurrent access")
        void testConcurrentAccess() throws InterruptedException {
            trans2QueryFSInfo = new Trans2QueryFSInformation(config, FileSystemInformation.SMB_INFO_ALLOCATION);
    
            final int THREAD_COUNT = 10;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  8. src/test/java/jcifs/internal/smb1/trans2/Trans2SetFileInformationTest.java

            // But we can verify the object is created successfully with these values
            assertNotNull(trans2SetFileInfo);
        }
    
        @Test
        @DisplayName("Test concurrent access")
        void testConcurrentAccess() throws InterruptedException {
            // Setup mock before creating the object
            when(mockFileInfo.getFileInformationLevel()).thenReturn((byte) FileInformation.FILE_BASIC_INFO);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/Ordering.java

    import java.util.List;
    import java.util.Map.Entry;
    import java.util.NoSuchElementException;
    import java.util.SortedMap;
    import java.util.SortedSet;
    import java.util.TreeSet;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.atomic.AtomicInteger;
    import org.jspecify.annotations.NonNull;
    import org.jspecify.annotations.Nullable;
    
    /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 17:50:58 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  10. guava/src/com/google/common/reflect/Types.java

    import java.lang.reflect.WildcardType;
    import java.security.AccessControlException;
    import java.util.Arrays;
    import java.util.Collection;
    import java.util.Map.Entry;
    import java.util.Objects;
    import java.util.concurrent.atomic.AtomicReference;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Utilities for working with {@link Type}.
     *
     * @author Ben Yu
     */
    final class Types {
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Oct 31 19:34:24 UTC 2025
    - 24.3K bytes
    - Viewed (0)
Back to top