Search Options

Results per page
Sort
Preferred Languages
Advance

Results 991 - 1000 of 1,022 for concurrency (0.1 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java

    import java.text.SimpleDateFormat;
    import java.util.ArrayList;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Locale;
    import java.util.Map;
    import java.util.concurrent.TimeUnit;
    import java.util.regex.Pattern;
    
    import javax.net.ssl.SSLContext;
    
    import org.apache.commons.io.output.DeferredFileOutputStream;
    import org.apache.commons.lang3.SystemUtils;
    import org.apache.http.Header;
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 52.2K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/ImmutableMap.java

    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import com.google.errorprone.annotations.DoNotCall;
    import com.google.errorprone.annotations.DoNotMock;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    import com.google.j2objc.annotations.RetainedWith;
    import com.google.j2objc.annotations.WeakOuter;
    import java.io.InvalidObjectException;
    import java.io.ObjectInputStream;
    import java.io.Serializable;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 44.3K bytes
    - Viewed (0)
  3. src/test/java/jcifs/smb/SmbFileIntegrationTest.java

            }
        }
    
        @Test
        void testSimpleMultipleFiles() throws Exception {
            // Test creating multiple files sequentially (simpler than concurrent access)
            for (int i = 0; i < 3; i++) {
                SmbFile file = new SmbFile(baseUrl + "shared/multi" + i + ".txt", context);
                String content = "Content for file " + i;
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 56K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/Iterables.java

       * @throws NoSuchElementException if the iterable is empty
       */
      @ParametricNullness
      public static <T extends @Nullable Object> T getLast(Iterable<T> iterable) {
        // TODO(kevinb): Support a concurrently modified collection?
        if (iterable instanceof List) {
          List<T> list = (List<T>) iterable;
          if (list.isEmpty()) {
            throw new NoSuchElementException();
          }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 43.3K bytes
    - Viewed (0)
  5. cmd/object-handlers_test.go

    }
    
    // Wrapper for calling NewMultipartUploadParallel tests for both Erasure multiple disks and single node setup.
    // The objective of the test is to initialte multipart upload on the same object 10 times concurrently,
    // The UploadID from the response body is parsed and its existence is asserted with an attempt to ListParts using it.
    func TestAPINewMultipartHandlerParallel(t *testing.T) {
    	defer DetectTestLeak(t)()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/collect/IteratorsTest.java

        assertTrue(cycle.hasNext());
        cycle.remove();
        assertEquals(emptyList(), iterable);
        assertFalse(cycle.hasNext());
      }
    
      /** An Iterable whose Iterator is rigorous in checking for concurrent modification. */
      private static final class PickyIterable<E> implements Iterable<E> {
        final List<E> elements;
        int modCount = 0;
    
        PickyIterable(E... elements) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 54.4K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/ImmutableMap.java

    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import com.google.errorprone.annotations.DoNotCall;
    import com.google.errorprone.annotations.DoNotMock;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    import com.google.j2objc.annotations.RetainedWith;
    import com.google.j2objc.annotations.WeakOuter;
    import java.io.InvalidObjectException;
    import java.io.ObjectInputStream;
    import java.io.Serializable;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 41.2K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/net/MediaType.java

    import com.google.common.collect.Multimaps;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import com.google.errorprone.annotations.Immutable;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    import java.nio.charset.Charset;
    import java.nio.charset.IllegalCharsetNameException;
    import java.nio.charset.UnsupportedCharsetException;
    import java.util.HashMap;
    import java.util.Map;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 48K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

    import java.security.cert.CertificateException
    import java.security.cert.X509Certificate
    import java.time.Duration
    import java.util.Arrays
    import java.util.EnumSet
    import java.util.Locale
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicReference
    import java.util.zip.GZIPInputStream
    import javax.net.SocketFactory
    import javax.net.ssl.SSLException
    import javax.net.ssl.SSLHandshakeException
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.15.md

    Check the [release notes website](https://relnotes.k8s.io/?releaseVersions=1.15.0) for the complete changelog of notable features and fixes.
    
    
    
    
    ## Known Issues
    
    - Concurrently joining control-plane nodes does not work as expected in kubeadm 1.15.0. The feature was planned for release in 1.15.0, but a fix may  come in a follow up patch release.
    
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Thu May 05 13:44:43 UTC 2022
    - 278.9K bytes
    - Viewed (0)
Back to top