isDone - Code Search

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

    assertFalse(task.isDone());
    assertFalse(task.isCancelled());

    // Start the task to put it in the RUNNING state.  Have to use a separate
    // thread because the task will block on the task latch after unblocking
    // the run latch.
    exec.execute(task);
    runLatch.await();
    assertEquals(1, listenerLatch.getCount());
    assertFalse(task.isDone());
    assertFalse(task.isCancelled());

Java

- Registered: Fri May 03 12:43:13 GMT 2024

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

- 4.7K bytes

- Viewed (0)

github.com/google/guava

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

    assertFalse(task.isDone());
    task.run();
    assertTrue(task.isDone());
    assertFalse(task.isCancelled());
    assertEquals(2, getDone(task).intValue());
  }

  public void testCancelled() throws Exception {
    TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2));
    assertFalse(task.isDone());
    task.cancel(false);
    assertTrue(task.isDone());

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Tue Feb 13 14:28:25 GMT 2024

- 7.3K bytes

- Viewed (0)

github.com/google/guava

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

    assertFalse(task.isDone());
    task.run();
    assertTrue(task.isDone());
    assertFalse(task.isCancelled());
    assertEquals(2, getDone(task).intValue());
  }

  public void testCancelled() throws Exception {
    TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2));
    assertFalse(task.isDone());
    task.cancel(false);
    assertTrue(task.isDone());

Java

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

- Last Modified: Tue Feb 13 14:28:25 GMT 2024

- 7.3K bytes

- Viewed (0)

github.com/google/guava

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

    assertTrue(future.isDone());
    assertFalse(future.isCancelled());

    assertEquals(expectedValue, future.get());
  }

  public void testCancelledFuture() throws InterruptedException, ExecutionException {
    assertTrue(future.isDone());
    assertTrue(future.isCancelled());

    assertTrue(latch.await(5, TimeUnit.SECONDS));
    assertTrue(future.isDone());
    assertTrue(future.isCancelled());

Java

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

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

- 3.3K bytes

- Viewed (0)

github.com/google/guava

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

    assertTrue(future.isDone());
    assertFalse(future.isCancelled());

    assertEquals(expectedValue, future.get());
  }

  public void testCancelledFuture() throws InterruptedException, ExecutionException {
    assertTrue(future.isDone());
    assertTrue(future.isCancelled());

    assertTrue(latch.await(5, TimeUnit.SECONDS));
    assertTrue(future.isDone());
    assertTrue(future.isCancelled());

Java

- Registered: Fri May 03 12:43:13 GMT 2024

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

- 3.3K bytes

- Viewed (0)

github.com/google/guava

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

    assertFalse(task.isDone());
    assertFalse(task.isCancelled());

    // Start the task to put it in the RUNNING state.  Have to use a separate
    // thread because the task will block on the task latch after unblocking
    // the run latch.
    exec.execute(task);
    runLatch.await();
    assertEquals(1, listenerLatch.getCount());
    assertFalse(task.isDone());
    assertFalse(task.isCancelled());

Java

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

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

- 4.7K bytes

- Viewed (0)

github.com/google/guava

android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

    }
  }

  /**
   * Tests that a canceled future throws a cancellation exception.
   *
   * <p>This method checks the cancel, isCancelled, and isDone methods.
   */
  public void testCanceledFutureThrowsCancellation() throws Exception {

    assertFalse(future.isDone());
    assertFalse(future.isCancelled());

    CountDownLatch successLatch = new CountDownLatch(1);

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Wed Sep 06 18:30:30 GMT 2023

- 6K bytes

- Viewed (0)

github.com/google/guava

guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

    }
  }

  /**
   * Tests that a canceled future throws a cancellation exception.
   *
   * <p>This method checks the cancel, isCancelled, and isDone methods.
   */
  public void testCanceledFutureThrowsCancellation() throws Exception {

    assertFalse(future.isDone());
    assertFalse(future.isCancelled());

    CountDownLatch successLatch = new CountDownLatch(1);

Java

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

- Last Modified: Wed Sep 06 18:30:30 GMT 2023

- 6K bytes

- Viewed (0)

github.com/google/guava

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

    assertFalse(listenableFuture.isDone());

    listenableFuture.addListener(singleCallListener, executorService);
    abstractFuture.set(DATA1);
    assertEquals(DATA1, listenableFuture.get());
    singleCallListener.waitForCall();

    assertTrue(spy.wasExecuted);
    assertTrue(singleCallListener.wasCalled());
    assertTrue(listenableFuture.isDone());
  }

Java

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

- Last Modified: Wed Feb 09 22:57:07 GMT 2022

- 9.7K bytes

- Viewed (0)

github.com/google/guava

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

    assertFalse(listenableFuture.isDone());

    listenableFuture.addListener(singleCallListener, executorService);
    abstractFuture.set(DATA1);
    assertEquals(DATA1, listenableFuture.get());
    singleCallListener.waitForCall();

    assertTrue(spy.wasExecuted);
    assertTrue(singleCallListener.wasCalled());
    assertTrue(listenableFuture.isDone());
  }

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Wed Feb 09 22:57:07 GMT 2022

- 9.7K bytes

- Viewed (0)

Search Options