Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for Queues (0.05 sec)

  1. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

                finishedSessionIdList.add(sessionId);
            }
        }
    
        /**
         * Deletes all data associated with a specific crawler session.
         * Removes URL filters, URL queues, and access result data for the session.
         *
         * @param sessionId the session ID whose data should be deleted
         */
        private void deleteBySessionId(final String sessionId) {
            try {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java

        assertFalse(segment.clearValueForTesting(key, hash, valueRef));
        segment.setWeakValueReferenceForTesting(entry, valueRef);
        assertTrue(segment.clearValueForTesting(key, hash, valueRef));
      }
    
      // reference queues
    
      public void testDrainKeyReferenceQueueOnWrite() {
        for (MapMaker maker : allWeakKeyStrengthMakers()) {
          MapMakerInternalMap<Object, Object, ?, ?> map = makeMap(maker.concurrencyLevel(1));
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 35.5K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java

        assertFalse(segment.clearValueForTesting(key, hash, valueRef));
        segment.setWeakValueReferenceForTesting(entry, valueRef);
        assertTrue(segment.clearValueForTesting(key, hash, valueRef));
      }
    
      // reference queues
    
      public void testDrainKeyReferenceQueueOnWrite() {
        for (MapMaker maker : allWeakKeyStrengthMakers()) {
          MapMakerInternalMap<Object, Object, ?, ?> map = makeMap(maker.concurrencyLevel(1));
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 35.5K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

          it.next();
          it.remove();
        }
        segment.evictEntries(entry);
        assertThat(map).hasSize(maxSize);
        assertThat(map).isEqualTo(originalMap);
      }
    
      // reference queues
    
      public void testDrainKeyReferenceQueueOnWrite() {
        for (CacheBuilder<Object, Object> builder : allKeyValueStrengthMakers()) {
          LocalCache<Object, Object> map = makeLocalCache(builder.concurrencyLevel(1));
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 115.9K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/cache/LocalCacheTest.java

          it.next();
          it.remove();
        }
        segment.evictEntries(entry);
        assertThat(map).hasSize(maxSize);
        assertThat(map).isEqualTo(originalMap);
      }
    
      // reference queues
    
      public void testDrainKeyReferenceQueueOnWrite() {
        for (CacheBuilder<Object, Object> builder : allKeyValueStrengthMakers()) {
          LocalCache<Object, Object> map = makeLocalCache(builder.concurrencyLevel(1));
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 117.5K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java

            return true;
        }
    
        /**
         * Stores child URLs from the given set into the crawling queue for future processing.
         * This method filters out blank URLs and increments the depth for child URLs.
         *
         * @param urlQueue the parent URL queue item
         * @param childUrlSet the set of child URLs to be queued for crawling
         */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Dec 11 09:47:03 UTC 2025
    - 19.5K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/SearchLogHelper.java

                    }
                }
            }
            return OptionalEntity.empty();
        }
    
        /**
         * Processes the search log queue.
         *
         * @param queue The search log queue.
         */
        protected void processSearchLogQueue(final Queue<SearchLog> queue) {
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final String value = fessConfig.getPurgeByBots();
            String[] botNames;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

        /**
         * Maximum size of the thumbnail generation task queue.
         */
        protected int thumbnailTaskQueueSize = 10000;
    
        /**
         * Number of tasks to process in bulk operations.
         */
        protected int thumbnailTaskBulkSize = 100;
    
        /**
         * Timeout in milliseconds for thumbnail task queue operations.
         */
        protected long thumbnailTaskQueueTimeout = 10 * 1000L;
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 27K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

      private void weaklyReferenceQueue() {
        frq = new FinalizableReferenceQueue();
        queueReference = new WeakReference<>(frq.queue);
    
        /*
         * Queue and clear a reference for good measure. We test later on that
         * the finalizer thread stopped, but we should test that it actually
         * started first.
         */
        reference =
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  10. CLAUDE.md

    ### Crawler (`Crawler.java`)
    
    Main orchestrator for crawling operations.
    
    **Key Methods**:
    ```java
    String execute()                // Start crawling, return session ID
    void addUrl(String url)         // Add URL to queue
    void cleanup(String sessionId)  // Clean up session
    void stop()                     // Stop gracefully
    ```
    
    **Key Fields**: `crawlerContext`, `urlFilter`, `intervalController`, `clientFactory`, `ruleManager`
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Fri Nov 28 17:31:34 UTC 2025
    - 10.7K bytes
    - Viewed (0)
Back to top