Как объединить эти два RunWith бегунов?

Я создал двух Runners, оба из которых унаследованы от BlockJUnit4ClassRunner. Одним из них является фильтрация некоторых тестов в зависимости от условий. Другой - запускать тестирование нескольких методов одновременно. Я хочу применить оба этих бегуна, чтобы тесты выполнялись в зависимости от условий и одновременно.

Проблема в том, что мы не можем аннотировать несколько @RunWith для одних и тех же тестов, в соответствии с несколькими утверждениями RunWith в jUnit.

Мой вопрос заключается в том, что оба эти бегуна унаследованы от одного и того же базового класса BlockJUnit4ClassRunner. Могу ли я объединить эти два бегуна в один, чтобы с помощью этого бегуна я мог запускать методы тестирования на основе условий и одновременного использования? И как это сделать?

Вот два бегуна, которых я создал:

1) Этот бегун запускает методы тестирования на основе некоторых условий, определенных в FunctionalTestFilter:

public class FilterRunner extends BlockJUnit4ClassRunner {

     public FilterRunner(Class<?> clazz) throws InitializationError {
        super(clazz);
        Filter f = new FunctionalTestFilter();
        try {
            f.apply(this);
        } catch (NoTestsRemainException ex) {
           System.out.println("Warning! No method run in " + clazz.getName());
        }
    }

2) Этот бегун запускает методы тестирования одновременно, используя многопоточность:

public static class ConcurrentJunitMethodRunner extends BlockJUnit4ClassRunner {
      public ConcurrentJunitMethodRunner(final Class<?> testclass) throws InitializationError {
          super(testclass);
          setScheduler(new RunnerScheduler() {
              ExecutorService executorService = Executors.newFixedThreadPool(5);
              CompletionService<Void> completionService = new ExecutorCompletionService<Void>(executorService);
              Queue<Future<Void>> tasks = new LinkedList<Future<Void>>();

              @Override
              public void schedule(Runnable childStatement) {
                  tasks.offer(completionService.submit(childStatement, null));
              }

              @Override
              public void finished() {
                  try {
                      while (!tasks.isEmpty())
                          tasks.remove(completionService.take());
                  } catch (InterruptedException e) { 
                      Thread.currentThread().interrupt();
                  } finally {
                      while (!tasks.isEmpty())
                          tasks.poll().cancel(true);
                      executorService.shutdownNow();
                  }
              }
          });
      }
  } 

0 ответов

Другие вопросы по тегам