Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 27 of 27 for ConcurrentLinkedQueue (0.58 sec)

  1. src/main/java/org/codelibs/fess/helper/SearchLogHelper.java

        protected int userInfoCacheSize = 10000;
    
        /** Queue for storing search logs. */
        protected Queue<SearchLog> searchLogQueue = new ConcurrentLinkedQueue<>();
    
        /** Queue for storing click logs. */
        protected Queue<ClickLog> clickLogQueue = new ConcurrentLinkedQueue<>();
    
        /** Cache for storing user information. */
        protected LoadingCache<String, UserInfo> userInfoCache;
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/exec/Crawler.java

    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Queue;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.CoreLibConstants;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 31.4K bytes
    - Viewed (0)
  3. docs/contribute/concurrency.md

    #### Per-Connection Locks
    
    Each connection has its own lock. The connections in the pool are all in a `ConcurrentLinkedQueue`. Due to data races, iterators of this queue may return removed connections. Callers must check the connection's `noNewExchanges` property before using connections from the pool.
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/collect/testing/Helpers.java

       *     the size method
       */
      public static <T extends @Nullable Object> Collection<T> misleadingSizeCollection(int delta) {
        // It would be nice to be able to return a real concurrent
        // collection like ConcurrentLinkedQueue, so that e.g. concurrent
        // iteration would work, but that would not be GWT-compatible.
        // We are not "just" inheriting from ArrayList here as this doesn't work for J2kt.
        return new AbstractList<T>() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Oct 10 23:13:45 UTC 2025
    - 17.2K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpClient.java

    import java.io.OutputStream;
    import java.net.URI;
    import java.net.URISyntaxException;
    import java.time.Duration;
    import java.util.HashSet;
    import java.util.Queue;
    import java.util.Set;
    import java.util.concurrent.ConcurrentLinkedQueue;
    
    import org.apache.commons.lang3.StringUtils;
    import org.apache.commons.net.ftp.FTP;
    import org.apache.commons.net.ftp.FTPClient;
    import org.apache.commons.net.ftp.FTPClient.NatServerResolverImpl;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 40K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/collect/testing/Helpers.java

       *     the size method
       */
      public static <T extends @Nullable Object> Collection<T> misleadingSizeCollection(int delta) {
        // It would be nice to be able to return a real concurrent
        // collection like ConcurrentLinkedQueue, so that e.g. concurrent
        // iteration would work, but that would not be GWT-compatible.
        // We are not "just" inheriting from ArrayList here as this doesn't work for J2kt.
        return new AbstractList<T>() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Oct 10 23:13:45 UTC 2025
    - 17.2K bytes
    - Viewed (0)
  7. guava/src/com/google/common/cache/LocalCache.java

    import java.util.LinkedHashSet;
    import java.util.Map;
    import java.util.NoSuchElementException;
    import java.util.Queue;
    import java.util.Set;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicReferenceArray;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 19:35:11 UTC 2025
    - 148.9K bytes
    - Viewed (0)
Back to top