Search Options

Results per page
Sort
Preferred Languages
Advance

Results 431 - 440 of 653 for threads (4.77 sec)

  1. guava/src/com/google/common/base/Suppliers.java

        public T get() {
          // Another variant of Double Checked Locking.
          //
          // We use two volatile reads. We could reduce this to one by
          // putting our fields into a holder class, but (at least on x86)
          // the extra memory consumption and indirection are more
          // expensive than the extra volatile reads.
          long nanos = expirationNanos;
          long now = System.nanoTime();
          if (nanos == 0 || now - nanos >= 0) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/suggest/Suggester.java

     *   <li>{@link #popularWords()}: Creates a new PopularWordsRequestBuilder for querying popular words.</li>
     *   <li>{@link #refresh()}: Refreshes the suggestion indices.</li>
     *   <li>{@link #shutdown()}: Shuts down the thread pool.</li>
     *   <li>{@link #createIndexIfNothing()}: Creates a new index if no index exists.</li>
     *   <li>{@link #createNextIndex()}: Creates a new index and replaces the current update alias with the new index.</li>
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 20.7K bytes
    - Viewed (1)
  3. src/main/java/org/codelibs/fess/ingest/IngestFactory.java

            // Default constructor
        }
    
        /**
         * Adds an ingester to the factory.
         * The ingester is inserted into the collection and the array is re-sorted by priority.
         * This method is thread-safe.
         *
         * @param ingester the ingester to add
         */
        public synchronized void add(final Ingester ingester) {
            if (logger.isDebugEnabled()) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/admin/crawlinginfo/AdminCrawlinginfoAction.java

                        throwValidationError(messages -> messages.addErrorsCrudCouldNotFindCrudTable(GLOBAL, id), this::asListHtml);
                        return null;
                    });
        }
    
        /**
         * Print a thread dump.
         * @param form The edit form.
         * @return The HTML response.
         */
        @Execute
        @Secured({ ROLE })
        public HtmlResponse threaddump(final EditForm form) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

        public void finalizeReferent() {
          finalizeReferentCalled = true;
        }
      }
    
      /**
       * Keeps a weak reference to the underlying reference queue. When this reference is cleared, we
       * know that the background thread has stopped and released its strong reference.
       */
      private WeakReference<ReferenceQueue<Object>> queueReference;
    
      @Test
      public void testThatFinalizerStops() {
        weaklyReferenceQueue();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

        public void finalizeReferent() {
          finalizeReferentCalled = true;
        }
      }
    
      /**
       * Keeps a weak reference to the underlying reference queue. When this reference is cleared, we
       * know that the background thread has stopped and released its strong reference.
       */
      private WeakReference<ReferenceQueue<Object>> queueReference;
    
      @Test
      public void testThatFinalizerStops() {
        weaklyReferenceQueue();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/AbstractConfigHelper.java

    /**
     * The abstract helper for configuration.
     *
     * This class provides a basic framework for managing configurations that can be reloaded.
     * It includes functionality for updating configurations in a separate thread and controlling the reloading interval.
     */
    public abstract class AbstractConfigHelper {
    
        /**
         * Default constructor.
         */
        public AbstractConfigHelper() {
            // Default constructor
        }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/unit/TestSystemProperties.java

                return null;
            }
        }
    
        private void loadTestProperties() {
            // Load system.properties from test classpath
            try (InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("system.properties")) {
                if (is != null) {
                    Properties props = new Properties();
                    props.load(is);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 2.5K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/job/ExecJobTest.java

            CountDownLatch latch = new CountDownLatch(2);
    
            Thread t1 = new Thread(() -> {
                for (int i = 0; i < 100; i++) {
                    execJob.jvmOptions("-Xmx" + i + "m");
                }
                latch.countDown();
            });
    
            Thread t2 = new Thread(() -> {
                for (int i = 0; i < 100; i++) {
                    execJob.jvmOptions("-Xms" + i + "m");
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 24.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

                SingletonLaContainerFactory.setExternalContextComponentDefRegister(new GenericExternalContextComponentDefRegister());
                SingletonLaContainerFactory.init();
    
                final Thread shutdownCallback = new Thread("ShutdownHook") {
                    @Override
                    public void run() {
                        if (logger.isDebugEnabled()) {
                            logger.debug("Destroying LaContainer..");
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 11K bytes
    - Viewed (0)
Back to top