Python日常笔记(24)- 进程

进程

一个程序运行起来后,代码+用到的资源 称之为进程,它是操作系统分配资源的基本单元。
不仅可以通过线程完成多任务,进程也是可以的

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】优质资源。

发布了55 篇原创文章 · 获赞 16 · 访问量 9510

猜你喜欢

转载自blog.csdn.net/duchaochen/article/details/105069114