寻求使用python基准测试程序最大化CPU利用率。

Question

我一直致力于用 python 开发一个综合基准测试程序，以便对班级项目的各种系统中的 CPU 进行压力测试。我的方法基于梅森素性测试（受到 prime95 的启发）。该程序旨在测试用户定义的工作集上数字的梅森素性。到目前为止，我已经在Python中实现了这个，但是一旦实现了concurrent.futures模块以便并行运行任务以最大化CPU利用率，我遇到了障碍。在测试我的程序时，我遇到了两个问题。

1. CPU 利用率仍然只有 ~35%
2. 当测试更大的工作集时，程序在开始迭代每个素数之前会停滞几分钟 - 我假设这与并发的设置有关。

我希望有人能够提供一些关于如何通过该程序最大限度地利用系统资源并解决较大集的问题的见解。

代码如下：

sys = platform.uname()
c = wmi.WMI()
winSys = c.Win32_ComputerSystem()[0]

mode1 = "Integer Mode"
mode2 = "Floating-Point Mode"

def lehmer(p: int) -> bool:

    s = 4
    M = (1 << p) - 1
    for i in range(p - 2):
        s = ((s * s) - 2) % M
    return s == 0





#Initial printout of system information and menu screen schowing benchamrking options
print("_________________________________________________________________________________")
print("------------------------------System Information---------------------------------")
print(f"\tOS: {sys.system} {sys.release} ") #
print(f"\tMachine Name: {sys.node}")
print(f"\tVersion: {sys.version}")
print(f"\tCPU: {sys.processor}")
print("\tNumber of Cores: " + str(psutil.cpu_count()))
print(f"\tRAM: {psutil.virtual_memory()}")
print("---------------------------------------------------------------------------------")


modeSelect = 0;
print("Welcome to ParaBench! Please select what benchmarking mode you would like to use." + '\n')
modeSelect = int(input("[1] -> " + mode1 + '\n' + "[2] -> " + mode2
    + "\n[9] -> Exit\n_________________________________________________________________________________\n"))


#User selects Integer benchmarking mode
if modeSelect == 1:
    print("User Selected " + mode1)

    #Printout of selection for order of magnitude
    print("[1] -> First 1x10^2 Primes\n" +  "[2] -> First 1x10^3 Primes\n"
        +"[3] -> First 1x10^4 Primes\n" + "[4] -> First 1x10^5 Primes\n" + "[5] -> First 1x10^6 Primes\n")
    mersenneOrder = int(input("Please Select an option\n"))


    if mersenneOrder == 1:
        print("Starting Benchmark...")
        with ThreadPoolExecutor(15) as executor:
            timeStart = perf_counter()

            for result in executor.map(lehmer,range(2,100)):
                print(result)
            timeStop = perf_counter()

            print("1E2 Benchmark Complete in ",timeStop-timeStart)


    if mersenneOrder == 2:
        print("Starting Benchmark...")
        with ThreadPoolExecutor(15) as executor:
            timeStart = perf_counter()

            for result in executor.map(lehmer,range(2,1000)):
                print(result)
            timeStop = perf_counter()
            print("1E3 Benchmark Complete!!", timeStop-timeStart)


    if mersenneOrder == 3:
        print("Starting Benchmark...")
        with ThreadPoolExecutor() as executor:
            timeStart = perf_counter()

            for result in executor.map(lehmer,range(2,10000)):
                print(result)
            timeStop = perf_counter()
            print("1E4 Benchmark Complete!!", timeStop-timeStart)


    if mersenneOrder == 4:
        print("Starting Benchmark...")
        with ThreadPoolExecutor(15) as executor:
            timeStart = perf_counter()

            for result in executor.map(lehmer,range(2,100000)):
                print(result)
            timeStop = perf_counter()
            print("1E5 Benchmark Complete!!", timeStop-timeStart)


    if mersenneOrder == 5:
        print("Starting Benchmark...")
        with ThreadPoolExecutor(15) as executor:
            timeStart = perf_counter()

            for result in executor.map(lehmer,range(2,1000000)):
                print(result)
            timeStop = perf_counter()
            print("1E6 Benchmark Complete!!", timeStop-timeStart)

        #Single-threaded test (DEPRECATED)
        #for x in range(2,1000000):
        #    if lehmer(x):
        #        print(x)