Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for isRunning (0.08 sec)

  1. src/test/java/org/codelibs/fess/it/CrawlTestBase.java

            Boolean isRunning = false;
            int count = 0;
    
            while (count < 300 && !isRunning) { // Wait until the crawler starts
                ThreadUtil.sleep(500);
                count++;
                final Map<String, Object> scheduler = getSchedulerItem(namePrefix);
                assertTrue(scheduler.containsKey("running"));
                isRunning = (Boolean) scheduler.get("running");
            }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        ListenableFuture<Boolean> future2 =
            serializer.submit(
                new Callable<Boolean>() {
                  @Override
                  public Boolean call() {
                    return blockingCallable.isRunning();
                  }
                },
                directExecutor());
    
        // Wait for the first task to be started in the background. It will block until we explicitly
        // stop it.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/DataIndexHelper.java

                    continue;
                }
    
                // check status
                for (int i = 0; i < startedCrawlerNum; i++) {
                    if (!dataCrawlingThreadList.get(i).isRunning() && Constants.RUNNING.equals(dataCrawlingThreadStatusList.get(i))) {
                        dataCrawlingThreadList.get(i).awaitTermination();
                        dataCrawlingThreadStatusList.set(i, Constants.DONE);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 12K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        ListenableFuture<Boolean> future2 =
            serializer.submit(
                new Callable<Boolean>() {
                  @Override
                  public Boolean call() {
                    return blockingCallable.isRunning();
                  }
                },
                directExecutor());
    
        // Wait for the first task to be started in the background. It will block until we explicitly
        // stop it.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/admin/scheduler/AdminSchedulerAction.java

                        form.crudMode = crudMode;
                        LaRequestUtil.getOptionalRequest().ifPresent(request -> {
                            request.setAttribute("running", entity.isRunning());
                            request.setAttribute("enabled", entity.isEnabled());
                        });
                    }).orElse(() -> {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  6. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  7. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  8. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  9. 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 Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jan 01 05:12:47 UTC 2018
    - 32.8K bytes
    - Viewed (0)
  10. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 10.7K bytes
    - Viewed (0)
Back to top