Python多线程

2020-12-20

进程：计算机中已运行程序的实体，进程是一个动态的概念，同时进程还是计算机中资源分配的最小单位。

线程：线程是cpu调度的基本单位，一个进程可以拥有多个线程。一个线程只属于一个进程。

在Python中有多个模块可以创建进程，比较常用的有os.fork(),multiprocessing模块和Pool进程池。os.fork()只适用于Unix/linux/MacOs中，在windows不能使用。

使用multiprocessing模块创建进程需要使用到Process类来生成一个进程对象。Process的构造函数如下：

1	Process([group[,target[,name[,args[,kwargs]]]]])

参数说明：

group : 参数未使用，始终未None
target : 可调用对象，表示要执行的任务
name: 当前进程的别名
args: 表示传递给target的参数
kwargs:表示传递给target函数的参数字典

Process类常用的方法：

is_alive() : 判断进程实例是否还在执行
join([timeout]) : 是否等待进程实例结束，或等待多少秒
start() : 启动进程(创建子进程)
run()： 如果没有给定target参数，调用start函数时，就执行对象的run函数
terminate(): 立即终止任务，不管任务是否完成

Process常用属性：

1 2	name: 当前进程的别名 pid ：进程实例的ID

示例代码如下：

from multiprocessing import Process
import os
import time
def child_process(interval):
    print("子进程 %s 开始执行，父进程为 %s"%(os.getpid(),os.getppid()))
    start = time.time()
    time.sleep(interval)
    end = time.time()
    print("子进程 %s 执行时间为 %s"%(os.getpid(),(end-start)))
def main():
    p1 = Process(target=child_process,args=(2,))
    p2 = Process(target=child_process,name="ss",args=(3,))
    p1.start()
    p2.start()
    print("p1 is alive = %s"%p1.is_alive())
    print("p2 is alive = %s" % p2.is_alive())
    print("p1 name is %s" % p1.name)
    print("p1 pid is %s" % p1.pid)
    print("p2 name is  %s" % p2.name)
    print("p2 pid is %s" % p2.pid)
    p1.join()
    p2.join()
    print("父进程执行结束")

if __name__ == '__main__':
    main()

也可以使用Process子类创建进程，不过要注意的是最好重写一下run函数，可以完成不同的任务，不重写run函数则会调用Process中的默认的run函数。示例代码如下：

rom multiprocessing import Process
import os
import time
class SubProcess(Process):
    def __init__(self,interval,name=''):
        super(SubProcess,self).__init__() #不调用父类的构造函数数，process的构造函数会被覆盖出现问题
        self.interval = interval
        if name:
            self.name = name
    #override the run function
    def run(self):
        print("子进程 %s 开始执行，父进程为 %s" % (os.getpid(), os.getppid()))
        start = time.time()
        time.sleep(self.interval)
        end = time.time()
        print("子进程 %s 执行时间为 %s" % (os.getpid(), (end - start)))

def main():
    p1 = SubProcess(2,'p1')
    p2 = SubProcess(3,"p2")
    #默认执行run 函数
    p1.start()
    p2.start()
    print("p1 is alive = %s" % p1.is_alive())
    print("p2 is alive = %s" % p2.is_alive())
    print("p1 name is %s" % p1.name)
    print("p1 pid is %s" % p1.pid)
    print("p2 name is  %s" % p2.name)
    print("p2 pid is %s" % p2.pid)
    p1.join()
    p2.join()
    print("父进程执行结束")
if __name__ == '__main__':
        main()

因为没有指定target参数，所以start函数默认会执行run函数