Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for isRunning (0.17 sec)

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

       */
      public boolean isRunning() {
        return isRunning;
      }
    
      /**
       * Starts the stopwatch.
       *
       * @return this {@code Stopwatch} instance
       * @throws IllegalStateException if the stopwatch is already running.
       */
      @CanIgnoreReturnValue
      public Stopwatch start() {
        checkState(!isRunning, "This stopwatch is already running.");
        isRunning = true;
        startTick = ticker.read();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/base/StopwatchTest.java

        assertTrue(startedStopwatch.isRunning());
      }
    
      public void testCreateUnstarted() {
        Stopwatch unstartedStopwatch = Stopwatch.createUnstarted();
        assertFalse(unstartedStopwatch.isRunning());
        assertEquals(0, unstartedStopwatch.elapsed(NANOSECONDS));
      }
    
      public void testInitialState() {
        assertFalse(stopwatch.isRunning());
        assertEquals(0, stopwatch.elapsed(NANOSECONDS));
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

      }
    
      @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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

      }
    
      @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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  5. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  6. 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: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 20 13:56:35 UTC 2025
    - 21.8K bytes
    - Viewed (0)
  7. 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: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java

        @Execute(urlPattern = "{}/@word")
        public JsonResponse<ApiResult> put$start(final String id) {
            scheduledJobService.getScheduledJob(id).ifPresent(entity -> {
                if (!entity.isEnabled() || entity.isRunning()) {
                    throwValidationErrorApi(messages -> {
                        messages.addErrorsFailedToStartJob(GLOBAL, entity.getName());
                    });
                }
                try {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sun Nov 23 12:34:02 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  9. 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: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 19K bytes
    - Viewed (0)
  10. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 25.5K bytes
    - Viewed (0)
Back to top