江苏龙网

  1. 首页 > 人文 > >

Python中实现多进程与多线程

进程与线程进程（process）就是任务 ， 是计算机系统进行资源分配和调度的基本单位 。 比如 ， 打开一个word文件就是启动了一个word进程 。
线程（thread）是进程内的子任务 。 比如word中可以进行编辑、拼写检查和打印等子任务 。
【Python中实现多进程与多线程】我们目前的操作系统都是多任务的操作系统 ， 多任务的实现方式：
多进程多线程多进程 + 多线程
多进程：multiprocessing模块Unix Like系统中 ， 可以用python中os模块的os.fork方法 ， 为当前进程创建一个“子进程” ， 当前进程称作“父进程” 。
说的简单一点 ， 就是当你调用os.fork以后 ， 会有两个进程运行这之后的代码 ， 它们的pid（process id）不一样 。
由于一些玄学或是一些不知名的原因 ， 用这个方法以后 ， 我心爱的mbp风扇呼呼响 ， 所以只好作罢 。
multiprocessing模块比os.fork好用的多 ， 这个模块也可以用于创建多进程 。 而且它有一些基本的对象如Queue等支持进程间通信 。 下面主要讨论用multiprocessing模块怎么实现多进程 。
创建一个子进程
multiprocessing.Process类可以初始化一个子进程 ， target参数传入子进程函数 。
from multiprocessing import Processimport os, time
# 子进程函数
def sub_process: print('Sub Process (%s) Start!' % os.getpid) for i in reversed(range(3)): time.sleep(1) print(i+1) time.sleep(1) print('Over!')print('Main Prcess (%s) Start!' % os.getpid)for i in reversed(range(3)): time.sleep(1) print(i+1)time.sleep(1)print('GO!')time.sleep(1)p = Process(target=sub_process)# 子进程开始p.start# 等待子进程结束p.join
代码执行的效果如下：
Python中实现多进程与多线程文章插图
创建多个子进程
multiprocessing.Pool类可以创建一个进程池 ， 进程吃通过调用apply_async函数来创建一个新的进程 。
from multiprocessing import Poolimport os,timedef sub_process(n): time.sleep(1) print('Process (%s) is running!' % os.getpid)# 指定同时运行的进程数p = Pool(4)for i in range(5): p.apply_async(sub_process,args=(i+1,))# 不能继续添加进程了p.closep.join
Python中实现多进程与多线程文章插图
可以清晰的看见 ， 我们指定了同时运行的进程数为4 ， 因此最开始添加的4个进程都停了1秒就有了输出 ， 而最后一个进程在1秒以后才有输出 。
多线程：threading模块多线程相比于多进程的好处是能更快一点 ， 但是也没快多少 。 python中常用threading模块实现多线程 。
import threading, timedef thread: print('%s is running' % threading.current_thread.name)print('%s is running' % threading.current_thread.name)time.sleep(1)t = threading.Thread(target=thread, name='Sub_Thread')t.startt.join
后记
当然多进程和多线程的内容远不止这些 ， 其他的还有进程间通信、线程中的锁、ThreadLocal等 。 由于立下了一天写一篇文章的flag ， 如果一开始就把这件事搞得非常复杂就会损失做这个事的乐趣 。 所以我打算偷点懒 ， 少点写 ， 以后再增加工作量～
以上是酷仔今日整理的“Python中实现多进程与多线程”一文 ， 希望为正在学习Python编程的同学提供参考 。


    推荐阅读


    上一篇：零基础小白必看：python基本操作-文件、目录及路径

    下一篇：阿里云自动巡检