博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
多进程复习
阅读量:5090 次
发布时间:2019-06-13

本文共 993 字,大约阅读时间需要 3 分钟。

# import os# #fork只能用于linux/unix中# pid = os.fork()# print("bobby")# if pid == 0:#   print('子进程 {} ,父进程是: {}.' .format(os.getpid(), os.getppid()))# else:#   print('我是父进程:{}.'.format(pid))import multiprocessing#多进程编程import timedef get_html(n):    time.sleep(n)    print("sub_progress success")    return nif __name__ == "__main__":    # progress = multiprocessing.Process(target=get_html, args=(2,))    # print(progress.pid)    # progress.start()    # print(progress.pid)    # progress.join()    # print("main progress end")    #使用线程池    pool = multiprocessing.Pool(multiprocessing.cpu_count())    # result = pool.apply_async(get_html, args=(3,))    #    # #等待所有任务完成    # pool.close()    # pool.join()    #    # print(result.get())    #imap    # for result in pool.imap(get_html, [1,5,3]):    #     print("{} sleep success".format(result))    for result in pool.imap_unordered(get_html, [1,5,3]):        print("{} sleep success".format(result))

 

转载于:https://www.cnblogs.com/Erick-L/p/8922417.html

你可能感兴趣的文章