python基础===多进程

from multiprocessing import Process
import os

# 子进程要执行的代码
def run_proc(name):
    print(‘Run child process %s (%s)...‘ % (name, os.getpid()))

if __name__==‘__main__‘:
    print(‘Parent process %s.‘ % os.getpid())
    p = Process(target=run_proc, args=(‘test‘,))
    print(‘Child process will start.‘)
    p.start()
    p.join()
    print(‘Child process end.‘)


>>>
Parent process 9860.
Child process will start.
Run child process test (9764)...
Child process end.

from multiprocessing import Pool
import os, time, random


def long_time_task(name):
    print("Run task %s (%s)...." % (name, os.getpid()))
    start = time.time()
    time.sleep(random.random()*3)
    end = time.time()
    print("Task %s runs %0.2f seconds." %(name, (end - start)))


if __name__ == "__main__":
    print("Parent process %s." %os.getpid())
    p = Pool(4)                         #允许运行多少个进程
    for i in range(5):
        p.apply_async(long_time_task, args = (i, ))
    print("waiting for all subprocesses done....")
    p.close()
    p.join()
    print("All  subprocesses done.")

>>>
Parent process 10852.
waiting for all subprocesses done....
Run task 0 (9620)....
Run task 1 (10180)....
Run task 2 (8116)....
Task 2 runs 0.03 seconds.
Run task 3 (8116)....
Run task 4 (8744)....
Task 4 runs 0.42 seconds.
Task 0 runs 0.64 seconds.
Task 1 runs 1.15 seconds.
Task 3 runs 2.90 seconds.
All  subprocesses done.