Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 411 for executeOn (0.04 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

        }
    
        eventListener.canceled(this)
      }
    
      override fun isCanceled(): Boolean = canceled
    
      override fun execute(): Response {
        check(executed.compareAndSet(false, true)) { "Already Executed" }
    
        timeout.enter()
        callStart()
        try {
          client.dispatcher.executed(this)
          return getResponseWithInterceptorChain()
        } finally {
          client.dispatcher.finished(this)
        }
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java

                        logger.debug("Process {} is already executed.", p);
                    }
                }
            }
    
            /**
             * Checks if the destroyer has been executed.
             * @return True if executed, false otherwise.
             */
            public boolean isExecuted() {
                return executed.get();
            }
        }
    
        /**
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Fri Jul 18 14:34:06 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * Executor ensuring that all Runnables submitted are executed in order, using the provided
     * Executor, and sequentially such that no two will ever be running at the same time.
     *
     * <p>Tasks submitted to {@link #execute(Runnable)} are executed in FIFO order.
     *
     * <p>The execution of tasks is done by one thread as long as there are tasks left in the queue.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/entity/SearchRenderData.java

        }
    
        /**
         * Sets the time taken to execute the search query in milliseconds.
         *
         * @param queryTime The query execution time in milliseconds
         */
        public void setQueryTime(final long queryTime) {
            this.queryTime = queryTime;
        }
    
        /**
         * Sets the actual search query executed against the search engine.
         *
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/auth/chain/CommandChain.java

    /**
     * Authentication chain implementation that executes external commands for user operations.
     * Provides user management through command-line tool execution for password changes and user deletion.
     */
    public class CommandChain implements AuthenticationChain {
    
        private static final Logger logger = LogManager.getLogger(CommandChain.class);
    
        /** Working directory for command execution. */
        protected File workingDirectory = null;
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/job/ExecJob.java

         *
         * @return the execution type (e.g., "crawler", "suggest", etc.)
         */
        protected abstract String getExecuteType();
    
        /**
         * Executes the job with the specified job executor.
         * This method sets the job executor and then calls the abstract execute method.
         *
         * @param jobExecutor the job executor to use for execution
         * @return the execution result message or summary
         */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/score/ScoreUpdaterTest.java

            scoreUpdater.addScoreBooster(booster2);
            scoreUpdater.addScoreBooster(booster3);
    
            // Clear execution order before test
            PriorityTrackingBooster.clearExecutionOrder();
    
            scoreUpdater.execute();
    
            // Due to integer overflow in comparator, execution order is affected for extreme values
            // The comparator b2 - b1 with MAX_VALUE and MIN_VALUE causes overflow
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

                crawlerContext.sessionId = sessionId;
            }
        }
    
        /**
         * Executes the crawling process.
         * Starts a new thread for the crawler and optionally waits for its termination.
         * @return The session ID of the crawling process.
         */
        public String execute() {
            parentThread = new Thread(this, "Crawler-" + crawlerContext.sessionId);
            parentThread.setDaemon(daemon);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

          if (executeImmediate) {
            new RunnableExecutorPair(runnable, executor).execute();
          }
        }
    
        void execute() {
          synchronized (runnables) {
            if (executed) {
              return;
            }
            executed = true;
          }
    
          while (!runnables.isEmpty()) {
            runnables.poll().execute();
          }
        }
    
        private static class RunnableExecutorPair {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/helper/DataIndexHelper.java

     * This class coordinates the execution of data store crawling processes,
     * managing multiple concurrent crawling threads and handling the indexing
     * of crawled documents into the search engine.
     *
     * <p>The DataIndexHelper supports:</p>
     * <ul>
     *   <li>Concurrent crawling of multiple data configurations</li>
     *   <li>Thread pool management for crawler execution</li>
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 18.9K bytes
    - Viewed (0)
Back to top