Почему выходные данные tqdm+joblib такие беспорядочные и что с этим можно сделать? ⇐ Python

[Anonymous]

Я хочу запускать процессы параллельно и показывать их прогресс. У меня есть этот код, который в основном взят из https://stackoverflow.com/a/79345626/1473517.

Код: Выделить всё

from math import factorial
from decimal import Decimal, getcontext
from concurrent.futures import ThreadPoolExecutor, as_completed
from tqdm import tqdm
import time

def calc(n_digits, pos, total):
# number of iterations
n = int(n_digits + 1 / 14.181647462725477)
n = n if n >= 1 else 1

# set the number of digits for our numbers
getcontext().prec = n_digits + 1

t = Decimal(0)
pi = Decimal(0)
deno = Decimal(0)

for k in tqdm(range(n), position=pos, desc=f"Job {pos + 1} of {total}", leave=True, dynamic_ncols=True):
t = ((-1) ** k) * (factorial(6 * k)) * (13591409 + 545140134 * k)
deno = factorial(3 * k) * (factorial(k) ** 3) * (640320 ** (3 * k))
pi += Decimal(t) / Decimal(deno)

pi = pi * Decimal(12) / Decimal(640320 ** Decimal(1.5))
pi = 1 / pi

# no need to round
return pi

def parallel_with_concurrent_futures():
# Define the number of threads to use
n_threads = 3
# Define the tasks (e.g., compute first 100, 200, 300, 400 digits of pi)
tasks = [1200, 1700, 900, 1400]  # Edit to make code for longer

# Create a list of tqdm objects to manage progress bars
progress_bars = [tqdm(total=int(task + 1 / 14.181647462725477), position=pos, desc=f"Job {pos + 1} of {len(tasks)}", leave=True, dynamic_ncols=True) for pos, task in enumerate(tasks)]

# Run tasks in parallel
with ThreadPoolExecutor(max_workers=n_threads) as executor:
futures = {executor.submit(calc, n, pos, len(tasks)): pos for pos, n in enumerate(tasks)}
for future in as_completed(futures):
pos = futures[future]
progress_bars[pos].close()  # Close the progress bar when the job is done
try:
result = future.result()
# Optionally, you can print the result here if needed
# print(f"Job {pos + 1} of {len(tasks)} completed with result: {result}")
except Exception as e:
print(f"Job {pos + 1} of {len(tasks)} failed with error: {e}")

if __name__ == "__main__":
parallel_with_concurrent_futures()

Однако, когда я запускаю его, я вижу, что результат постепенно ухудшается. Все начинается с:

Я именно этого и хочу. Но затем, после завершения первого процесса, я получаю:


Проблема началась. Затем позже появляется:

Это еще хуже. А затем, когда он завершается, отображается:


Как я могу изменить код, чтобы он по-прежнему использовал 3 ядра параллельно, но я вижу только что-то вроде первого из изображений выше? Я не против использования других модулей, кроме concurrent и tqdm, если это правильно.

Подробнее здесь: https://stackoverflow.com/questions/793 ... e-about-it