本文整理了Java中com.linkedin.parseq.Task.isDone()方法的一些代码示例，展示了Task.isDone()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Task.isDone()方法的具体详情如下：
包路径：com.linkedin.parseq.Task
类名称：Task
方法名：isDone

Task.isDone介绍

暂无

代码示例

代码示例来源：origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public boolean isDone() {
 return _task.isDone();
}

代码示例来源：origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public boolean isDone() {
 return _task.isDone();
}

代码示例来源：origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public boolean isDone() {
 return _task.isDone();
}

代码示例来源：origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public boolean isDone() {
 return _task.isDone();
}

代码示例来源：origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public boolean isDone() {
 return _task.isDone();
}

代码示例来源：origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public boolean isDone() {
 return _task.isDone();
}

代码示例来源：origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public boolean isDone() {
 return _task.isDone();
}

代码示例来源：origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public boolean isDone() {
 return _task.isDone();
}

代码示例来源：origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public boolean isDone() {
 return _task.isDone();
}

代码示例来源：origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public boolean isDone() {
 return _task.isDone();
}

代码示例来源：origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public boolean isDone() {
 return _task.isDone();
}

代码示例来源：origin: linkedin/parseq

@Test
public void testWithSideEffectPartial() {
 Task<String> fastMain = getSuccessTask();
 Task<String> slowSideEffect = delayedValue("slooow", 5100, TimeUnit.MILLISECONDS);
 Task<String> partial = fastMain.withSideEffect(s -> slowSideEffect);
 // ensure the whole task can finish before individual side effect task finishes
 runAndWait("AbstractTaskTest.testWithSideEffectPartial", partial);
 assertTrue(fastMain.isDone());
 assertTrue(partial.isDone());
 assertFalse(slowSideEffect.isDone());
}

代码示例来源：origin: linkedin/parseq

public void testWithSideEffectFullCompletion(int expectedNumberOfTasks) throws Exception {
 Task<String> fastMain = getSuccessTask();
 Task<String> slowSideEffect = delayedValue("slow", 50, TimeUnit.MILLISECONDS);
 Task<String> full = fastMain.withSideEffect(s -> slowSideEffect);
 // ensure the side effect task will be run
 runAndWait("AbstractTaskTest.testWithSideEffectFullCompletion", full);
 slowSideEffect.await();
 assertTrue(full.isDone());
 assertTrue(fastMain.isDone());
 assertTrue(slowSideEffect.isDone());
 assertEquals(countTasks(full.getTrace()), expectedNumberOfTasks);
}

代码示例来源：origin: linkedin/parseq

@Test
public void testSimpleRetryPolicy()
{
 Task<Void> task = withRetryPolicy("testSimpleRetryPolicy", RetryPolicy.attempts(3, 0),
   attempt -> Task.failure(new RuntimeException("current attempt: " + attempt)));
 runAndWaitException(task, RuntimeException.class);
 assertTrue(task.isDone());
 assertEquals(task.getError().getMessage(), "current attempt: 2");
}

代码示例来源：origin: linkedin/parseq

@Test
public void testSimpleRetryPolicy()
{
 Task<Void> task = withRetryPolicy("testSimpleRetryPolicy", RetryPolicy.attempts(3, 0),
   attempt -> Task.failure(new RuntimeException("current attempt: " + attempt)));
 runAndWaitException(task, RuntimeException.class);
 assertTrue(task.isDone());
 assertEquals(task.getError().getMessage(), "current attempt: 2");
}

代码示例来源：origin: linkedin/parseq

@Test
public void testSuccessfulTask()
{
 Task<String> task = withRetryPolicy(RetryPolicy.attempts(3, 0), attempt -> Task.value("successful attempt " + attempt));
 runAndWait(task);
 assertTrue(task.isDone());
 assertEquals(task.get(), "successful attempt 0");
}

代码示例来源：origin: linkedin/parseq

@Test
public void testSuccessfulTask()
{
 Task<String> task = withRetryPolicy(RetryPolicy.attempts(3, 0), attempt -> Task.value("successful attempt " + attempt));
 runAndWait(task);
 assertTrue(task.isDone());
 assertEquals(task.get(), "successful attempt 0");
}

代码示例来源：origin: linkedin/parseq

@Test
public void testToTryCancelled() throws InterruptedException {
 Task<String> cancelMain = delayedValue("value", 6000, TimeUnit.MILLISECONDS);
 Task<Try<String>> task = cancelMain.toTry();
 run(task);
 assertTrue(cancelMain.cancel(new Exception("canceled")));
 task.await();
 assertTrue(task.isDone());
 assertTrue(task.isFailed());
 assertTrue(Exceptions.isCancellation(task.getError()));
 logTracingResults("AbstractTaskTest.testToTryCancelled", task);
}

代码示例来源：origin: linkedin/parseq

private <T> void assertDone(final Task<T> task, final T expectedValue) {
 assertTrue(task.isDone());
 assertFalse(task.isFailed());
 assertEquals(expectedValue, task.get());
 assertNull(task.getError());
 assertTrue(task.getShallowTrace().getStartNanos() > 0);
 assertTrue(task.getShallowTrace().getStartNanos() <= task.getShallowTrace().getEndNanos());
}

代码示例来源：origin: linkedin/parseq

private void assertFailed(final Task<?> task, Exception exception) {
 assertTrue(task.isDone());
 assertTrue(task.isFailed());
 assertEquals(exception, task.getError());
 assertTrue(task.getShallowTrace().getStartNanos() > 0);
 assertTrue(task.getShallowTrace().getStartNanos() <= task.getShallowTrace().getEndNanos());
 try {
  task.get();
  fail("Should have thwon PromiseException");
 } catch (PromiseException e) {
  assertEquals(exception, e.getCause());
 }
}