@chenwei123
2018-02-06T02:27:14.000000Z
字数 666
阅读 374
Python
from multiprocessing import Processimport osdef run_proc(name):print("Run child process %s (%s)..." %(name, os.getpid()))if __name__ == '__main__':print("Parent process %s." % os.getpid())p=Process(targent=run_proc, args=('test',))print('Child process will start.')p.start() #启动p.join() #等待子进程结束后再继续往下运行print("Child process end.")
from multiprocessing import Poolimport os, time, randomdef 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,))