进程
一个程序运行起来后,代码+用到的资源 称之为进程,它是操作系统分配资源的基本单元。
不仅可以通过线程完成多任务,进程也是可以的
multiprocessing模块就是跨平台版本的多进程模块,提供了一个Process类来代表一个进程对象,这个对象可以理解为是一个独立的进程,可以执行另外的事情
语法:
Process([group [, target [, name [, args [, kwargs]]]]])
target:如果传递了函数的引用,可以任务这个子进程就执行这里的代码
args:给target指定的函数传递的参数,以元组的方式传递
kwargs:给target指定的函数传递命名参数
name:给进程设定一个名字,可以不设定
group:指定进程组,大多数情况下用不到
Process创建的实例对象的常用方法:
start():启动子进程实例(创建子进程)
is_alive():判断进程子进程是否还在活着
join([timeout]):是否等待子进程执行结束,或等待多少秒
terminate():不管任务是否完成,立即终止子进程
Process创建的实例对象的常用属性:
name:当前进程的别名,默认为Process-N,N为从1开始递增的整数
pid:当前进程的pid(进程号)
代码演示:
import multiprocessing
import time
def set_num1(name, age):
while True:
print(f"1-----{name},{age}------------")
time.sleep(1)
def set_num2(name, age):
while True:
print(f"2-----{name},{age}------------")
time.sleep(1)
if __name__ == "__main__":
# 创建进程
p1 = multiprocessing.Process(target=set_num1, args=('zhangsan', 18))
p2 = multiprocessing.Process(target=set_num2, args=('lisi', 20))
p1.start()
p2.start()
注意:进程间的全局变量是不能共享的
进程和线程区别
1.进程,能够完成多任务,比如 在一台电脑上能够同时运行多个QQ
2.线程,能够完成多任务,比如 一个QQ中的多个聊天窗口
3.进程是系统进行资源分配和调度的一个独立单位.
4.线程是进程的一个实体,是CPU调度和分派的基本单位,它是比进程更小的能独立运行的基本单位.线程自己基本上不拥有系统资源,只拥有一点在运行中必不可少的资源(如程序计数器,一组寄存器和栈),但是它可与同属一个进程的其他的线程共享进程所拥有的全部资源.
5.一个程序至少有一个进程,一个进程至少有一个线程.
6.线程的划分尺度小于进程(资源比进程少),使得多线程程序的并发性高。
进程在执行过程中拥有独立的内存单元,而多个线程共享内存,从而极大地提高了程序的运行效率
7.线线程不能够独立执行,必须依存在进程中
优缺点
线程和进程在使用上各有优缺点:线程执行开销小,但不利于资源的管理和保护;而进程正相反。
进程间通信
进程间通信可以使用multiprocessing模块的Queue实现多进程之间的数据传递,Queue本身是一个消息列队程序,先进先出。
Queue()对象时(例如:q=Queue()),若括号中没有指定最大可接收的消息数量,或数量为负值,那么就代表可接受的消息数量没有上限(直到内存的尽头);
Queue.qsize():返回当前队列包含的消息数量;
Queue.empty():如果队列为空,返回True,反之False ;
Queue.full():如果队列满了,返回True,反之False;
Queue.get([block[, timeout]]):获取队列中的一条消息,然后将其从列队中移除,block默认值为True;
import multiprocessing
import time
# 保存数据
def set_num1(temp_queue):
list1 = [1, 2, 3, 4, 5, 6]
for temp in list1:
temp_queue.put(temp)
print(f"保存数据成功:{list1}")
# 获取数据
def set_num2(temp_queue):
while True:
if temp_queue.empty():
break
print(f"打印数据:{temp_queue.get()}")
time.sleep(1)
if __name__ == "__main__":
temp_queue = multiprocessing.Queue()
# 创建进程
p1 = multiprocessing.Process(target=set_num1, args=(temp_queue,))
p2 = multiprocessing.Process(target=set_num2, args=(temp_queue,))
p1.start()
p2.start()
作者:阿超
原创公众号:『Python日常笔记』,专注于 Python爬虫等技术栈和有益的程序人生,会将一些平时的日常笔记都慢慢整理起来,也期待你的关注和阿超一起学习,公众号回复【csdn】优质资源。