Search Options

Results per page
Sort
Preferred Languages
Advance

Results 691 - 700 of 931 for CONCURRENT (0.04 sec)

  1. guava-tests/test/com/google/common/hash/BloomFilterTest.java

    import static com.google.common.hash.Funnels.unencodedCharsFunnel;
    import static com.google.common.truth.Truth.assertThat;
    import static java.nio.charset.StandardCharsets.UTF_8;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.base.Stopwatch;
    import com.google.common.collect.ImmutableSet;
    import com.google.common.hash.BloomFilterStrategies.LockFreeBitArray;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 22K bytes
    - Viewed (0)
  2. fess-crawler/src/test/java/org/codelibs/fess/crawler/rule/RuleTest.java

    import java.io.ObjectInputStream;
    import java.io.ObjectOutputStream;
    import java.io.Serializable;
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.codelibs.fess.crawler.entity.ResponseData;
    import org.codelibs.fess.crawler.processor.ResponseProcessor;
    import org.dbflute.utflute.core.PlainTestCase;
    
    /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Wed Sep 03 14:42:53 UTC 2025
    - 22.7K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java

    import static org.junit.Assert.assertTrue;
    
    import java.util.Collections;
    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.Map;
    import java.util.Random;
    import java.util.Set;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.codelibs.fess.suggest.Suggester;
    import org.codelibs.fess.suggest.settings.SuggestSettings;
    import org.codelibs.opensearch.runner.OpenSearchRunner;
    import org.junit.AfterClass;
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 9K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb/SmbTransportImpl.java

    import java.util.Collections;
    import java.util.LinkedList;
    import java.util.List;
    import java.util.ListIterator;
    import java.util.Locale;
    import java.util.Set;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicLong;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.Address;
    import jcifs.CIFSContext;
    import jcifs.CIFSException;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 69.8K bytes
    - Viewed (0)
  5. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt

     * limitations under the License.
     */
    package okhttp3.sse.internal
    
    import assertk.assertThat
    import assertk.assertions.containsExactly
    import assertk.assertions.isEqualTo
    import java.util.concurrent.TimeUnit
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.junit5.StartStop
    import okhttp3.Headers
    import okhttp3.OkHttpClientTestRule
    import okhttp3.RecordingEventListener
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:47:47 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  6. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/Platform.java

    package com.google.common.collect;
    
    import java.util.Arrays;
    import java.util.Collections;
    import java.util.LinkedHashMap;
    import java.util.LinkedHashSet;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.ConcurrentHashMap;
    import jsinterop.annotations.JsMethod;
    import jsinterop.annotations.JsPackage;
    import jsinterop.annotations.JsProperty;
    import jsinterop.annotations.JsType;
    import org.jspecify.annotations.Nullable;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Jun 10 15:17:16 UTC 2025
    - 5.5K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/curl/CurlRequest.java

    import java.io.UnsupportedEncodingException;
    import java.net.HttpURLConnection;
    import java.net.Proxy;
    import java.net.URL;
    import java.net.URLEncoder;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.ForkJoinPool;
    import java.util.function.BiConsumer;
    import java.util.function.Consumer;
    import java.util.function.Supplier;
    import java.util.logging.Logger;
    import java.util.zip.GZIPInputStream;
    
    Registered: Thu Sep 04 15:34:10 UTC 2025
    - Last Modified: Sat Jul 05 01:38:18 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  8. tests/associations_many2many_test.go

    	}
    	wg.Wait()
    
    	var find User
    	err = db.Preload(clause.Associations).Where("id = ?", user.ID).First(&find).Error
    	AssertEqual(t, err, nil)
    	AssertAssociationCount(t, find, "Languages", int64(count), "after concurrent append")
    }
    
    func TestMany2ManyDuplicateBelongsToAssociation(t *testing.T) {
    	user1 := User{Name: "TestMany2ManyDuplicateBelongsToAssociation-1", Friends: []*User{
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Sat Jun 10 13:05:19 UTC 2023
    - 13.2K bytes
    - Viewed (0)
  9. README.md

    ```java
    // Increase timeout values
    client.setConnectionTimeout(60000);  // 60 seconds
    client.setSocketTimeout(120000);     // 120 seconds
    ```
    
    #### Memory Issues
    ```java
    // Reduce concurrent threads and batch sizes
    crawler.crawlerContext.setNumOfThread(5);
    crawler.crawlerContext.setMaxAccessCount(1000);
    ```
    
    #### SSL/TLS Issues
    ```java
    // Configure SSL settings
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Aug 31 05:32:52 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt

    import assertk.assertions.isIn
    import java.io.IOException
    import java.net.InetSocketAddress
    import java.net.UnknownHostException
    import java.time.Duration
    import java.util.Arrays
    import java.util.concurrent.TimeUnit
    import kotlin.test.assertFailsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.junit5.StartStop
    import okhttp3.Headers.Companion.headersOf
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 9.8K bytes
    - Viewed (0)
Back to top