Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 33 for stopping (0.03 sec)

  1. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

          runningTask.cancel(false);
          executorService.execute(
              () -> {
                try {
                  lock.lock();
                  try {
                    if (state() != State.STOPPING) {
                      // This means that the state has changed since we were scheduled. This implies
                      // that an execution of runOneIteration has thrown an exception and we have
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

         */
        @PreDestroy
        public void destroy() {
            if (!finishCrawling) {
                if (logger.isInfoEnabled()) {
                    logger.info("Stopping all crawler.");
                }
                forceStop();
            }
        }
    
        /**
         * Adds a finished session ID to the cleanup list.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 32.7K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

          runningTask.cancel(false);
          executorService.execute(
              () -> {
                try {
                  lock.lock();
                  try {
                    if (state() != State.STOPPING) {
                      // This means that the state has changed since we were scheduled. This implies
                      // that an execution of runOneIteration has thrown an exception and we have
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/SystemHelper.java

            return new File(LaServletContextUtil.getServletContext().getRealPath(path));
        }
    
        /**
         * Checks if the system is in a force-stop state.
         *
         * @return true if the system is force-stopping, false otherwise.
         */
        public boolean isForceStop() {
            return forceStop.get();
        }
    
        /**
         * Sets the force-stop state of the system.
         *
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Aug 31 08:19:00 UTC 2025
    - 36.6K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/thumbnail/impl/HtmlTagBasedGenerator.java

     * and format settings.
     *
     * <p>The generator validates image MIME types, processes image data through
     * ImageIO operations, and applies scaling and cropping to generate thumbnails
     * that meet the specified size requirements.</p>
     *
     */
    public class HtmlTagBasedGenerator extends BaseThumbnailGenerator {
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/base/FessSearchAction.java

         * and form inputs for the given parameters.
         *
         * @param paramMap the parameter map to process
         * @param queryKey the key for storing query string parameters
         * @param formKey the key for storing form input parameters
         */
        protected void buildInitParamMap(final Map<String, String> paramMap, final String queryKey, final String formKey) {
            if (!paramMap.isEmpty()) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 13.8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/collect/PeekingIteratorTest.java

      }
    
      public void testPeekingIteratorBehavesLikeIteratorOnSingletonIterable() {
        actsLikeIteratorHelper(singletonList(new Object()));
      }
    
      // TODO(cpovirk): instead of skipping, use a smaller number of steps
      @GwtIncompatible // works but takes 5 minutes to run
      public void testPeekingIteratorBehavesLikeIteratorOnThreeElementIterable() {
        actsLikeIteratorHelper(Lists.newArrayList("A", "B", "C"));
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.6K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

            logger.info("Creating new suggest index.");
            suggestHelper.suggester().createNextIndex();
    
            logger.info("Storing all bad words.");
            suggestHelper.storeAllBadWords(true);
    
            logger.info("Storing all elevate words.");
            suggestHelper.storeAllElevateWords(true);
    
            final AtomicInteger exitCode = new AtomicInteger(0);
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 11K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/Striped.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * A striped {@code Lock/Semaphore/ReadWriteLock}. This offers the underlying lock striping similar
     * to that of {@code ConcurrentHashMap} in a reusable form, and extends it for semaphores and
     * read-write locks. Conceptually, lock striping is the technique of dividing a lock into many
     * <i>stripes</i>, increasing the granularity of a single lock and allowing independent operations
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/service/StopwordsService.java

    import org.dbflute.optional.OptionalEntity;
    
    import jakarta.annotation.Resource;
    
    /**
     * Service for managing stopwords.
     * This class provides methods to interact with stopwords dictionaries,
     * including retrieving, storing, and deleting stopwords.
     */
    public class StopwordsService {
        /** The dictionary manager for accessing dictionary files. */
        @Resource
        protected DictionaryManager dictionaryManager;
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 4.6K bytes
    - Viewed (0)
Back to top