Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 337 for enqueue (0.06 sec)

  1. docs/fr/docs/history-design-future.md

    D'après la dernière <a href="https://www.jetbrains.com/research/python-developers-survey-2018/#development-tools" class="external-link" target="_blank">Enquête Développeurs Python</a>, cela couvre environ 80% des utilisateurs.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Jul 29 23:35:07 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/MemoryDataHelper.java

    import java.util.LinkedList;
    import java.util.List;
    import java.util.Map;
    import java.util.Queue;
    import java.util.regex.Pattern;
    
    import org.codelibs.fess.crawler.entity.AccessResultImpl;
    import org.codelibs.fess.crawler.entity.UrlQueueImpl;
    
    /**
     * @author shinsuke
     *
     */
    public class MemoryDataHelper {
        protected volatile Map<String, Queue<UrlQueueImpl<Long>>> urlQueueMap = new HashMap<>();
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImpl.java

            final String url = urlQueue.getUrl();
            if (StringUtil.isBlank(url)) {
                if (logger.isDebugEnabled()) {
                    logger.debug("URL is a blank: {}", url);
                }
                return false;
            }
    
            // check it in queue
            for (final UrlQueue<Long> urlInQueue : urlQueueList) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/SearchLogHelper.java

                final Queue<SearchLog> queue = searchLogQueue;
                searchLogQueue = new ConcurrentLinkedQueue<>();
                processSearchLogQueue(queue);
            }
    
            if (!clickLogQueue.isEmpty()) {
                final Queue<ClickLog> queue = clickLogQueue;
                clickLogQueue = new ConcurrentLinkedQueue<>();
                processClickLogQueue(queue);
            }
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jul 22 02:07:37 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  5. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

            }
        }
    
        @Override
        public OpenSearchUrlQueue poll(final String sessionId) {
            final QueueHolder queueHolder = getQueueHolder(sessionId);
            final Queue<OpenSearchUrlQueue> waitingQueue = queueHolder.waitingQueue;
            final Queue<OpenSearchUrlQueue> crawlingQueue = queueHolder.crawlingQueue;
            OpenSearchUrlQueue urlQueue = waitingQueue.poll();
            if (urlQueue != null) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/collect/testing/TestStringQueueGenerator.java

    import java.util.List;
    import java.util.Queue;
    
    /**
     * Create queue of strings for tests.
     *
     * @author Jared Levy
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public abstract class TestStringQueueGenerator implements TestQueueGenerator<String> {
      @Override
      public SampleElements<String> samples() {
        return new Strings();
      }
    
      @Override
      public Queue<String> create(Object... elements) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 21 16:49:06 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/ForwardingQueue.java

    import java.util.NoSuchElementException;
    import java.util.Queue;
    import javax.annotation.CheckForNull;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * A queue which forwards all its method calls to another queue. Subclasses should override one or
     * more methods to modify the behavior of the backing queue as desired per the <a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 29 19:42:21 UTC 2021
    - 4.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/cache/ReferenceEntry.java

      /** Returns the next entry in the access queue. */
      ReferenceEntry<K, V> getNextInAccessQueue();
    
      /** Sets the next entry in the access queue. */
      void setNextInAccessQueue(ReferenceEntry<K, V> next);
    
      /** Returns the previous entry in the access queue. */
      ReferenceEntry<K, V> getPreviousInAccessQueue();
    
      /** Sets the previous entry in the access queue. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 15 18:00:07 UTC 2021
    - 3.5K bytes
    - Viewed (0)
  9. guava/src/com/google/common/cache/LocalCache.java

        /**
         * A queue of elements currently in the map, ordered by write time. Elements are added to the
         * tail of the queue on write.
         */
        @GuardedBy("this")
        final Queue<ReferenceEntry<K, V>> writeQueue;
    
        /**
         * A queue of elements currently in the map, ordered by access time. Elements are added to the
         * tail of the queue on access (note that writes count as accesses).
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 149.2K bytes
    - Viewed (0)
  10. samples/crawler/src/main/java/okhttp3/sample/Crawler.java

     */
    public final class Crawler {
      private final OkHttpClient client;
      private final Set<HttpUrl> fetchedUrls = Collections.synchronizedSet(new LinkedHashSet<>());
      private final LinkedBlockingQueue<HttpUrl> queue = new LinkedBlockingQueue<>();
      private final ConcurrentHashMap<String, AtomicInteger> hostnames = new ConcurrentHashMap<>();
    
      public Crawler(OkHttpClient client) {
        this.client = client;
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Aug 12 07:26:27 UTC 2021
    - 4.6K bytes
    - Viewed (0)
Back to top