Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 22 for isRunning (0.07 sec)

  1. src/main/java/org/codelibs/fess/opensearch/config/exentity/ScheduledJob.java

        public boolean isCrawlerJob() {
            return Constants.T.equals(getCrawler());
        }
    
        public boolean isEnabled() {
            return Constants.T.equals(getAvailable());
        }
    
        public boolean isRunning() {
            return ComponentUtil.getJobManager().findJobByUniqueOf(LaJobUnique.of(getId())).map(LaScheduledJob::isExecutingNow).orElse(false);
        }
    
        public void start() {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

                delegate.awaitTerminated(timeout, unit);
              }
    
              @Override
              public final boolean isRunning() {
                return delegate.isRunning();
              }
    
              @Override
              public final State state() {
                return delegate.state();
              }
    
              @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 20:34:52 UTC 2025
    - 25.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

       * get detailed information about which services are not running.
       */
      public boolean isHealthy() {
        for (Service service : services) {
          if (!service.isRunning()) {
            return false;
          }
        }
        return true;
      }
    
      /**
       * Provides a snapshot of the current state of all the services under management.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  4. src/main/webapp/js/admin/plugins/form-validator/jquery.form-validator.min.js

    tr("disabled","disabled"))}};d.prototype.reset=function(){this.haltedFormValidation=!1,this.hasRun=!1,this.isRunning=!1,this.result=c},d.prototype.run=function(a,b){return"keyup"===a?null:this.isRunning?(f=a,this.haltedFormValidation||(g.haltValidation(),this.haltedFormValidation=!0),null):this.hasRun?this.result:(f=a,g.haltValidation(this.$form),this.haltedFormValidation=!0,this.isRunning=!0,this.$input.attr("disabled","disabled").addClass("async-validation"),this.$form.addClass("async-validati...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Mon Jan 01 05:12:47 UTC 2018
    - 32.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Service.java

       * @since 15.0
       */
      @CanIgnoreReturnValue
      Service startAsync();
    
      /** Returns {@code true} if this service is {@linkplain State#RUNNING running}. */
      boolean isRunning();
    
      /** Returns the lifecycle state of the service. */
      State state();
    
      /**
       * If the service is {@linkplain State#STARTING starting} or {@linkplain State#RUNNING running},
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

        return getClass().getSimpleName();
      }
    
      @Override
      public String toString() {
        return serviceName() + " [" + state() + "]";
      }
    
      @Override
      public final boolean isRunning() {
        return delegate.isRunning();
      }
    
      @Override
      public final State state() {
        return delegate.state();
      }
    
      /**
       * @since 13.0
       */
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

        return getClass().getSimpleName();
      }
    
      @Override
      public String toString() {
        return serviceName() + " [" + state() + "]";
      }
    
      @Override
      public final boolean isRunning() {
        return delegate.isRunning();
      }
    
      @Override
      public final State state() {
        return delegate.state();
      }
    
      /**
       * @since 13.0
       */
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/Service.java

       * @since 15.0
       */
      @CanIgnoreReturnValue
      Service startAsync();
    
      /** Returns {@code true} if this service is {@linkplain State#RUNNING running}. */
      boolean isRunning();
    
      /** Returns the lifecycle state of the service. */
      State state();
    
      /**
       * If the service is {@linkplain State#STARTING starting} or {@linkplain State#RUNNING running},
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/AbstractService.java

            case FAILED:
              // Do nothing
              break;
          }
        } finally {
          monitor.leave();
          dispatchListenerEvents();
        }
      }
    
      @Override
      public final boolean isRunning() {
        return state() == RUNNING;
      }
    
      @Override
      public final State state() {
        return snapshot.externalState();
      }
    
      /**
       * @since 14.0
       */
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/job/CrawlJob.java

                cb.query().setCrawler_Equal(Constants.T);
            }, scheduledJob -> {
                if (fessConfig.isSchedulerTarget(scheduledJob.getTarget())) {
                    if (scheduledJob.isRunning()) {
                        if (logger.isDebugEnabled()) {
                            logger.debug("{} is running.", scheduledJob.getId());
                        }
                        counter.incrementAndGet();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.6K bytes
    - Viewed (0)
Back to top