Class ParallelComputerBuilder.PC

    • Field Detail

      • suites

        private final java.util.Collection<org.junit.runners.ParentRunner> suites
      • nestedSuites

        private final java.util.Collection<org.junit.runners.ParentRunner> nestedSuites
      • classes

        private final java.util.Collection<org.junit.runners.ParentRunner> classes
      • nestedClasses

        private final java.util.Collection<org.junit.runners.ParentRunner> nestedClasses
      • notParallelRunners

        private final java.util.Collection<org.junit.runner.Runner> notParallelRunners
      • poolCapacity

        private int poolCapacity
      • splitPool

        private boolean splitPool
      • allGroups

        private final java.util.Map<Type,​java.lang.Integer> allGroups
      • nestedClassesChildren

        private long nestedClassesChildren
    • Constructor Detail

      • PC

        private PC()
    • Method Detail

      • getSuites

        java.util.Collection<org.junit.runners.ParentRunner> getSuites()
      • getNestedSuites

        java.util.Collection<org.junit.runners.ParentRunner> getNestedSuites()
      • getClasses

        java.util.Collection<org.junit.runners.ParentRunner> getClasses()
      • getNestedClasses

        java.util.Collection<org.junit.runners.ParentRunner> getNestedClasses()
      • getNotParallelRunners

        java.util.Collection<org.junit.runner.Runner> getNotParallelRunners()
      • getPoolCapacity

        int getPoolCapacity()
      • isSplitPool

        boolean isSplitPool()
      • getSuite

        public org.junit.runner.Runner getSuite​(org.junit.runners.model.RunnerBuilder builder,
                                                java.lang.Class<?>[] cls)
                                         throws org.junit.runners.model.InitializationError
        Overrides:
        getSuite in class org.junit.runner.Computer
        Throws:
        org.junit.runners.model.InitializationError
      • getRunner

        protected org.junit.runner.Runner getRunner​(org.junit.runners.model.RunnerBuilder builder,
                                                    java.lang.Class<?> testClass)
                                             throws java.lang.Throwable
        Overrides:
        getRunner in class org.junit.runner.Computer
        Throws:
        java.lang.Throwable
      • wrapRunners

        private <T extends org.junit.runner.Runner> WrappedRunners wrapRunners​(java.util.Collection<T> runners)
                                                                        throws org.junit.runners.model.InitializationError
        Throws:
        org.junit.runners.model.InitializationError
      • countChildren

        private int countChildren​(org.junit.runner.Runner runner)
      • createPool

        private java.util.concurrent.ExecutorService createPool​(int poolSize)
      • createMaster

        private Scheduler createMaster​(java.util.concurrent.ExecutorService pool,
                                       int poolSize)
      • countFinalRunners

        private int countFinalRunners()
      • populateChildrenFromSuites

        private void populateChildrenFromSuites()
      • totalPoolSize

        private int totalPoolSize()
      • setSchedulers

        private org.junit.runner.Runner setSchedulers​(org.junit.runners.ParentRunner suiteSuites,
                                                      org.junit.runners.ParentRunner suiteClasses)
                                               throws org.junit.runners.model.InitializationError
        Throws:
        org.junit.runners.model.InitializationError
      • createFinalRunner

        private org.junit.runners.ParentRunner createFinalRunner​(java.util.List<org.junit.runner.Runner> runners)
                                                          throws org.junit.runners.model.InitializationError
        Throws:
        org.junit.runners.model.InitializationError
      • setSchedulers

        private void setSchedulers​(java.lang.Iterable<? extends org.junit.runners.ParentRunner> runners,
                                   int poolSize,
                                   java.util.concurrent.ExecutorService commonPool)
      • createScheduler

        private Scheduler createScheduler​(org.junit.runner.Description desc,
                                          java.util.concurrent.ExecutorService pool,
                                          boolean doParallel,
                                          Balancer concurrency)
      • createScheduler

        private Scheduler createScheduler​(int poolSize)
      • canSchedule

        private boolean canSchedule​(org.junit.runner.Runner runner)
      • isThreadSafe

        private boolean isThreadSafe​(org.junit.runner.Runner runner)