并发编程

1,什么是进程

进程是一个程序运行的过程,负责执行任务的是CPU

2,什么是程序

程序就是一堆代码文件

3,串行,并发,并行

串行:多个任务依次运行,一个运行完毕再运行下一个

并行:多个任务是真的在同时运行,只有多个cpu才有并行的概念

并发:多个任务看起来是在同时运行

4,进程的创建

windows:CreateProcess

Linux: fork

5,进程的终止

1,正常的退出

2,被其他的进程杀死(taskill /F /PID 3333)

6,程序运行的三种状态

运行态

就绪态

阻塞态

优化程序效率的核心法则:降低IO操作(硬盘IO,网络IO)

内存>本地硬盘>网络IO

7,进程运行的三种状态:

(运行态,就绪态)非阻塞态,阻塞态

调用任务的两种方式:同步调用,异步调用

同步:

就是在发出一个功能调用时,在没有结果之前,该调用就不会返回

异步:

当一个异步功能调用发出后,调用者不能立刻得到结果

阻塞:

阻塞调用指调用结果返回之前,当前线程就会被挂起(如遇到IO操作).函数只有

在得到结果之后才会将阻塞的线程激活

非阻塞:

指在不能立刻得到结果之前也会立刻返回,同时该函数不会阻塞当前线程

Process类介绍

创建进程的类

Process([group [, target [, name [, args [, kwargs]]]]])，由该类实例化得到的对象，表示一个子进程中的任务（尚未启动）

强调:

1,需要使用关键字的方式来指定参数

2,args指定的为传给target函数的位置参数,是一个元祖形式,必须有逗号

参数介绍

1 group参数未使用，值始终为None
2 
3 target表示调用对象，即子进程要执行的任务
4 
5 args表示调用对象的位置参数元组，args=(1,2,'egon',)
6 
7 kwargs表示调用对象的字典,kwargs={'name':'egon','age':18}
8 
9 name为子进程的名称

方法介绍:


 1 p.start()：启动进程，并调用该子进程中的p.run() 
 2 p.run():进程启动时运行的方法，正是它去调用target指定的函数，我们自定义类的类中一定要实现该方法  
 3 
 4 p.terminate():强制终止进程p，不会进行任何清理操作，如果p创建了子进程，该子进程就成了僵尸进程，使用该方法需要特别小心这种情况。如果p还保存了一个锁那么也将不会被释放，进而导致死锁
 5 p.is_alive():如果p仍然运行，返回True
 6 
 7 p.join([timeout]):主线程等待p终止（强调：是主线程处于等的状态，而p是处于运行的状态）。timeout是可选的超时时间，需要强调的是，p.join只能join住start开启的进程，而不能join住run开启的进程

属性介绍:

p.daemon：默认值为False，如果设为True，代表p为后台运行的守护进程，当p的父进程终止时，p也随之终止，并且设定为True后，p不能创建自己的新进程，必须在p.start()之前设置

p.name:进程的名称

p.pid：进程的pid

p.exitcode:进程在运行时为None、如果为–N，表示被信号N结束(了解即可)

p.authkey:进程的身份验证键,默认是由os.urandom()随机生成的32字符的字符串。这个键的用途是为涉及网络连接的底层进程间通信提供安全性，这类连接只有在具有相同的身份验证键时才能成功（了解即可）

ps:在windows中Process()必须放到# if name == 'main':下

开启进程的方式一:

import os,time
from multiprocessing import Process

def task(n,tag):
    print("%s is running"% tag)
    time.sleep(3)
    print("%s is done"% tag)
    
if __name__=='__main__'
	p1 = Process(target=task,args=(5,"子进程1"))
    p2 = Process(target=task,args=(4,"子进程2"))
    p3 = Process(target=task,args=(3,"子进程3"))
    
    p1.start()
    p2.start()
    p3.start()
    print('主:%s....'% os.getpid())

开启进程的方式二:

import os,time
from multiprocessing import Process

class Myprocess(Process):
	def __init__(self,tag):
		super().__init__()
		self.tag = tag
	
	def run(self) -> None:
		print("%s is running"% self.tag)
		time.sleep(3)
		print("%s is done"% self.tag )


if __name__=='__main__'
	p1 = Myprocess("进程1")
    p2 = Myprocess("进程2")
    p3 = Myprocess("进程3")
    
    p1.start()
    p2.start()
    p3.start()
    print("主:%s...."% os.getpid())

join方法

import os,time
from multiprocessing import Process


def task(n,tag)
	print("%s is running"% tag)
    time.sleep(n)
    print("%s is done"% tag)
    
if __name__=='__main__':
    p1 = Process(target=task,args=(3,'子进程1'))
    p2 = Process(target=task,args=(4,'子进程2'))
    p3 = Process(target=task,args=(5,'子进程3'))
    
    p1.start()
    p2.start()
    p3.start()
    
    p1.join()
    p2.join()
    p3.join()
    
    
    print(p1.pid)
    print(p2.pid)
    print(p3.pid)
    
    print("主:%s...."% os.getpid())