jck28-lucio-junit5并行策略【进阶】

学习笔记
1

并行策略配置

  • JUnit 提供了两种实现（动态和固定）和一个自定义选项。
  • junit.jupiter.execution.parallel.config.strategy 的值设为并行策略配置参数中的一种即可。
  • 如果没有进行策略的相关配置，并行化策略默认为dynamic

并行策略配置参数

  • 并发策略的配置参数有3种：dynamic、fixed、custom
  • 前两种dynamic和fixed是JUnit 平台提供的 开箱即用 的实现。
  • custom 策略是通过自定义的模式来配置并行的线程池数量。

dynamic

  • 动态策略;默认选项
junit.jupiter.execution.parallel.config.strategy = dynamic
  • 所需的并行数 根据 ++处理器/内核的数量++ 乘以 ++使用指定的因子参数++（默认为 1）确定线程数。
  • 并发线程数为 可用处理器/核的数量 * 系数
  • 系数设置
    • dynamic对应的系数配置项为：junit.jupiter.execution.parallel.config.dynamic.factor
    • 系数默认值为1

fixed

  • 固定策略
junit.jupiter.execution.parallel.config.strategy = fixed
  • 所需的并行数 固定策略依赖于预定义的线程数
  • 并发线程数为 设置的 junit.jupiter.execution.parallel.config.fixed.parallelism 的value 值

#4：测试类并行，测试方法并行
junit.jupiter.execution.parallel.mode.default = concurrent
junit.jupiter.execution.parallel.mode.classes.default=concurrent
#固定策略
junit.jupiter.execution.parallel.config.strategy = fixed
junit.jupiter.execution.parallel.config.fixed.parallelism=2

custom

  • 自定义策略
  • 通过实现 ParallelExecutionConfigurationStrategy 接口来配置并行的线程池数量。
junit.jupiter.execution.parallel.config.strategy = custom
  • 所需的并行数
    • 使用 ParallelExecutionConfigurationStrategy 接口实现。

custom

  • 自定义策略
  • 通过实现 ParallelExecutionConfigurationStrategy 接口来配置并行的线程池数量。
junit.jupiter.execution.parallel.config.strategy = custom
  • 所需的并行数
    • 使用 ParallelExecutionConfigurationStrategy 接口实现。
package com.junit5;

import org.junit.platform.commons.JUnitException;
import org.junit.platform.engine.ConfigurationParameters;
import org.junit.platform.engine.support.hierarchical.ParallelExecutionConfiguration;
import org.junit.platform.engine.support.hierarchical.ParallelExecutionConfigurationStrategy;

public class MyCustomStratgy implements ParallelExecutionConfigurationStrategy {
    @Override
    public ParallelExecutionConfiguration createConfiguration(ConfigurationParameters configurationParameters) {
        int count = configurationParameters.get("custom.parallelism", Integer::valueOf)
                .orElseThrow(() -> {
                    return new JUnitException(String.format("Configuration parameter '%s' must be set\", \"fixed.parallelism"));
                });
        return new ParallelExecutionConfiguration() {
            @Override
            public int getParallelism() {
                return count;
            }

            @Override
            public int getMinimumRunnable() {
                return count;
            }

            @Override
            public int getMaxPoolSize() {
                return count;
            }

            @Override
            public int getCorePoolSize() {
                return count;
            }

            @Override
            public int getKeepAliveSeconds() {
                return count;
            }
        };
    }
}

#4：测试类并行，测试方法并行
junit.jupiter.execution.parallel.mode.default = concurrent
junit.jupiter.execution.parallel.mode.classes.default=concurrent

#自定义策略
junit.jupiter.execution.parallel.config.strategy = custom
junit.jupiter.execution.parallel.config.custom.class = com.junit5.MyCustomStratgy
junit.jupiter.execution.parallel.config.custom.parallelism = 3

image
image808×692 67.3 KB