isRunning - Code Search

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));
  }

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Fri Feb 09 15:49:48 GMT 2024

- 5.8K bytes

- Viewed (0)

github.com/codelibs/fess

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");
        }

Java

- Registered: Mon Apr 22 08:04:10 GMT 2024

- Last Modified: Thu Feb 22 01:37:57 GMT 2024

- 9.9K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

    assertEquals(State.NEW, service.state());
    assertFalse(service.isRunning());
    assertFalse(service.running);

    service.startAsync();
    assertEquals(State.RUNNING, service.state());
    assertTrue(service.isRunning());
    assertTrue(service.running);

    service.stopAsync();
    assertEquals(State.TERMINATED, service.state());
    assertFalse(service.isRunning());
    assertFalse(service.running);
    assertEquals(

Java

- Registered: Fri Apr 12 12:43:09 GMT 2024

- Last Modified: Wed Sep 06 17:04:31 GMT 2023

- 29.3K bytes

- Viewed (0)

github.com/google/guava

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));
  }

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Fri Feb 09 15:49:48 GMT 2024

- 5.8K bytes

- Viewed (0)

github.com/google/guava

android/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();

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Tue Nov 15 21:38:09 GMT 2022

- 8.5K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

    val idleCallback: Runnable?
    this.withLock {
      if (!calls.remove(call)) throw AssertionError("Call wasn't in-flight!")
      idleCallback = this.idleCallback
    }

    val isRunning = promoteAndExecute()

    if (!isRunning && idleCallback != null) {
      idleCallback.run()
    }
  }

  /** Returns a snapshot of the calls currently awaiting execution. */
  fun queuedCalls(): List<Call> =

Plain Text

- Registered: Fri Apr 26 11:42:10 GMT 2024

- Last Modified: Sat Apr 20 17:03:43 GMT 2024

- 9K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

    assertEquals(State.NEW, service.state());
    assertFalse(service.isRunning());
    assertFalse(service.running);

    service.startAsync();
    assertEquals(State.RUNNING, service.state());
    assertTrue(service.isRunning());
    assertTrue(service.running);

    service.stopAsync();
    assertEquals(State.TERMINATED, service.state());
    assertFalse(service.isRunning());
    assertFalse(service.running);
    assertEquals(

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Sep 06 17:04:31 GMT 2023

- 29.3K bytes

- Viewed (0)

github.com/google/guava

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();

Java

- Registered: Fri Apr 05 12:43:09 GMT 2024

- Last Modified: Thu Feb 23 15:09:35 GMT 2023

- 9.2K bytes

- Viewed (0)

github.com/google/guava

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

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Dec 13 19:45:20 GMT 2023

- 7.6K bytes

- Viewed (0)

github.com/codelibs/fess

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);

Java

- Registered: Mon Apr 22 08:04:10 GMT 2024

- Last Modified: Thu Feb 22 01:37:57 GMT 2024

- 12K bytes

- Viewed (0)

Search Options