parallel_write.py 文件源码

def main(args):
    with open(args.src, 'r') as f:
        data = f.read()

    timer = Value('d', 0)
    processes = []
    for process_id in range(args.nprocess):
        p = Process(target=run_write, args=(args, data, process_id, timer))
        processes.append(p)
    start_time = time.time()
    for p in processes:
        p.start()
    for p in processes:
        p.join()
    average_time_per_process = timer.value / len(processes)
    print_stats(args, average_time_per_process)