在套件级别并行运行JUnit测试？
|
我有一堆在JUnit测试套件中组织的测试。这些测试极大地利用了硒来测试Web应用程序。因此，对于硒来说，这些测试的运行时间很长。由于套件中的测试类由于测试数据库中的某些重叠而无法并行运行，因此我想并行运行套件。
JUnit ParallelComputer只能在类或方法级别上并行执行测试，JUnit是否有使用套件进行标准化操作的标准方法？
如果我只是将套件类传递给junit运行程序，并将计算机配置为在类级别并行化，则它将选择测试类本身，而不是套件。
br
坦率
没有找到相关结果
已邀请:
2 个回复
玩翁文醚碱
而不是应该可以。还有一个需要的注释，可以在下面找到。package utilities.runners; import org.junit.internal.builders.AllDefaultPossibilitiesBuilder; import org.junit.runner.Runner; import org.junit.runners.Suite; import org.junit.runners.model.InitializationError; import org.junit.runners.model.RunnerBuilder; import org.junit.runners.model.RunnerScheduler; import utilities.annotations.Concurrent; import java.util.Arrays; import java.util.LinkedList; import java.util.List; import java.util.Queue; import java.util.concurrent.CompletionService; import java.util.concurrent.ExecutorCompletionService; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.ThreadFactory; import java.util.concurrent.atomic.AtomicInteger; /** * @author Mathieu Carbou (mathieu.carbou@gmail.com) */ public final class ConcurrentSuite extends Suite { public ConcurrentSuite(final Class<?> klass) throws InitializationError { super(klass, new AllDefaultPossibilitiesBuilder(true) { @Override public Runner runnerForClass(Class<?> testClass) throws Throwable { List<RunnerBuilder> builders = Arrays.asList( new RunnerBuilder() { @Override public Runner runnerForClass(Class<?> testClass) throws Throwable { Concurrent annotation = testClass.getAnnotation(Concurrent.class); if (annotation != null) return new ConcurrentJunitRunner(testClass); return null; } }, ignoredBuilder(), annotatedBuilder(), suiteMethodBuilder(), junit3Builder(), junit4Builder()); for (RunnerBuilder each : builders) { Runner runner = each.safeRunnerForClass(testClass); if (runner != null) return runner; } return null; } }); setScheduler(new RunnerScheduler() { ExecutorService executorService = Executors.newFixedThreadPool( klass.isAnnotationPresent(Concurrent.class) ? klass.getAnnotation(Concurrent.class).threads() : (int) (Runtime.getRuntime().availableProcessors() * 1.5), new NamedThreadFactory(klass.getSimpleName())); 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(); } } }); } static final class NamedThreadFactory implements ThreadFactory { static final AtomicInteger poolNumber = new AtomicInteger(1); final AtomicInteger threadNumber = new AtomicInteger(1); final ThreadGroup group; NamedThreadFactory(String poolName) { group = new ThreadGroup(poolName + \"-\" + poolNumber.getAndIncrement()); } @Override public Thread newThread(Runnable r) { return new Thread(group, r, group.getName() + \"-thread-\" + threadNumber.getAndIncrement(), 0); } } }package utilities.annotations; import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * @author Mathieu Carbou (mathieu.carbou@gmail.com) */ @Retention(RetentionPolicy.RUNTIME) @Target({ ElementType.TYPE }) public @interface Concurrent { int threads() default 5; }诫商
方式运行带有注释的类。是带有套件注释的类。@RunWith(Suite.class) @Suite.SuiteClasses({ Test1.class, Test2.class}) public class Suite1 { } @RunWith(Suite.class) @Suite.SuiteClasses({ Test3.class, Test4.class}) public class Suite2 { } ... JUnitCore.runClasses(ParallelComputer.classes(), new Class[]{Suite1.class, Suite2.class})