multi_progress_bar.py

from multiprocessing import Pool
import time
import random

number_list = []


def sub_process(i, number):
    rand = random.random()
    time.sleep(rand)
    # print('subprocess {}'.format(i))
    return i, number


def log(args):
    i = args[0]
    total_number = args[1]
    # print(args)
    number_list.append(i)
    number = len(number_list)
    percent = float(number) / total_number
    print('percent is {:.2%} number is {}'.format(percent, number))


def main():
    pool = Pool(processes=20)
    number = 1000
    for i in range(1000):
        pool.apply_async(sub_process, (i, number), callback=log)
    pool.close()
    pool.join()


if __name__ == '__main__':
    main()