如果在另一个线程中引发异常，则单元测试失败

Question

目前，每当我需要响应另一个线程中抛出的异常而使测试失败时，我都会编写如下内容：

package com.example;

import java.util.ArrayList;
import java.util.List;
import org.testng.annotations.Test;

import static java.util.Arrays.asList;
import static java.util.Collections.synchronizedList;
import static org.testng.Assert.fail;

public final class T {
  @Test
  public void testFailureFromLambda() throws Throwable {
    final List<Throwable> errors = synchronizedList(new ArrayList<>());

    asList("0", "1", "2").parallelStream().forEach(s -> {
      try {
        /*
         * The actual code under test here.
         */
        throw new Exception("Error " + s);
      } catch (final Throwable t) {
        errors.add(t);
      }
    });

    if (!errors.isEmpty()) {
      errors.forEach(Throwable::printStackTrace);

      final Throwable firstError = errors.iterator().next();
      fail(firstError.getMessage(), firstError);
    }
  }
}

同步列表可以替换为AtomicReference<Throwable>，但通常代码几乎相同。

是否有任何标准（并且不那么冗长）的方法可以使用 Java 中提供的任何测试框架（TestNG、JUnit、Hamcrest、AssertJ 等.)？

Answer 1

默认情况下，当一个测试方法抛出异常时，TestNG 会失败。我相信同样的事情也会发生在 JUnit 上，如果它抛出意外的异常，它会将测试标记为 errored。

如果您要处理Streams，那么您需要将它包装在RuntimeException 变体中，这样Java 就不会抱怨。 TestNG 会自动使测试失败。

这是一个示例：

@Test
public void testFailureFromLambdaRefactored() {
    asList("0", "1", "2").parallelStream().forEach(s -> {
        try {
        /*
        * The actual code under test here.
        */
            if (s.equals("2")) {
                throw new Exception("Error " + s);
            }
        } catch (final Throwable t) {
            throw new RuntimeException(t);
        }
    });
}

这适用于涉及 lambda 和流的场景。一般来说，如果您想了解从 @Test 方法分离出来的新线程中发生的异常，则需要使用 ExecutorService。

这是一个示例：

@Test
public void testFailureInAnotherThread() throws InterruptedException, ExecutionException {
    List<String> list = asList("0", "1", "2");
    ExecutorService service = Executors.newFixedThreadPool(2);
    List<Future<Void>> futures = service.invokeAll(Arrays.asList(new Worker(list)));
    for (Future future : futures) {
        future.get();
    }

}

public static class Worker implements Callable<Void> {
    private List<String> list;

    public Worker(List<String> list) {
        this.list = list;
    }

    @Override
    public Void call() throws Exception {
        for (String s : list) {
            if (s.equals("2")) {
                throw new Exception("Error " + s);
            }
        }
        return null;
    }
}