35并行/发同/异步非/阻塞开进程的两种方式,进程的常用方法及属性使用进程实现socket聊天...

from multiprocessing import Process
import os
import time
def func(i):time.sleep(0.2)print(&＃39;这是子进程%s,pid为%s ,其父进程的pid为%s&＃39; % (i, os.getpid(), os.getppid()))
# os.getpid(), 获得当前进程的pid,
# os.getppid(),获得当前进程的父进程的pid
if __name__ &＃61;&＃61; &＃39;__main__&＃39;:for i in range(2):p &＃61; Process(target&＃61;func, args&＃61;(i,)) #实例化一个进程对象#target:子进程要执行的任务,args:父进程要给子进程传递的参数,必须是元祖形式.p.start() #开启一个进程.time.sleep(0.2)print(&＃39;这是父进程, pid为%s, 其父进程的pid为%s&＃39; % (os.getpid(), os.getppid()))


from multiprocessing import Process
import time
import os
class Myprocess(Process):def __init__(self):super(Myprocess, self).__init__()def run(self):print(&＃39;在类中创建子进程&＃39;)
if __name__ &＃61;&＃61; &＃39;__main__&＃39;:p &＃61; Myprocess()p.start() #是指解释器告诉操作系统, 去帮我开启一个进程, 就绪状态p.run() # 解释器告诉操作系统,马上帮我执行这个过程. 执行状态


from multiprocessing import Process
import time
import os
class Myprocess(Process):def __init__(self, name):self.name &＃61; namesuper(Myprocess, self).__init__(name &＃61; name) # 如果不写在执行父类中的__init是name会被覆盖.def run(self):print(&＃39;这是以类的方式开启的子进程, 名字为%s&＃39; % self.name)
if __name__ &＃61;&＃61; &＃39;__main__&＃39;:p &＃61; Myprocess(&＃39;alex&＃39;)p.start() #是指解释器告诉操作系统, 去帮我开启一个进程, 就绪状态.# p.run() # 解释器告诉操作系统立即去开启一个进程, 执行状态.


from multiprocessing import Process
import os
import time
def func():for i in range(100):time.sleep(0.1)print(&＃39;这是子进程&＃39;)
if __name__ &＃61;&＃61; &＃39;__main__&＃39;:p &＃61; Process(target&＃61;func) #子进程要执行的任务p.start()# p.join() #是让主进程等待子进程执行完, 现象 : 主进程走到这句话, 主进程阻塞住, 等待子进程执行完.for i in range(100):time.sleep(0.1)print(&＃39;这是父进程&＃39;)
# 开启一个正常的子进程&＃xff0c;父进程会等待子进程结束后&＃xff0c;父进程也就是程序才结束
# p.join()# 是让主进程等待子进程执行完。 现象&＃xff1a;主进程执行到这句话&＃xff0c;主进程阻塞住&＃xff0c;等待子进程执行
# 如何把父进程和子进程之间的关系变为同步或者异步&＃xff1f;
# 父进程执行join&＃xff0c;就会变成同步&＃xff0c;不执行join&＃xff0c;父进程和子进程就是异步的关系
# join必须放在start()后边


from multiprocessing import Process
import time
import random
def func(i):time.sleep(1)print(&＃39;我是%s&＃39;%i)
if __name__ &＃61;&＃61; &＃39;__main__&＃39;:l &＃61; []addr &＃61; [&＃39;河南的&＃39;,&＃39;山东的&＃39;,&＃39;辽宁的&＃39;,&＃39;湖南的&＃39;]for i in addr:p &＃61; Process(target&＃61;func,args&＃61;(i,)) #实例化一个进程对象p.start()p.join()#开启一个进程l.append(p)for k in l: [k.join() for k in l]k.join() #此时这四个进程已经开启,同时jion, time.sleep(1)print(&＃39;我选%s&＃39;%(random.choice(addr)))


def func():time.sleep(1)
if __name__ &＃61;&＃61; &＃39;__main__&＃39;:p &＃61; Process(target&＃61;func,)p.start()p.terminate()# 杀死p进程,让解释器告诉操作系统&＃xff0c;请杀掉p进程。print(&＃39;子进程是否还活着&＃xff1f;&＃39;, p.is_alive())time.sleep(0.002)print(&＃39;子进程是否还活着&＃xff1f;&＃39;, p.is_alive())# 返回一个bool值&＃xff0c;如果返回True&＃xff0c;代表进程还活着,如果返回False&＃xff0c;代表子进程死了
# p.is_alive() 判断p进程是否还活着
# p.terminate() 杀死p进程


from multiprocessing import Process
import time
import os
def func():print(&＃39;这是子进程, pid为%s&＃39; % os.getpid())
if __name__ &＃61;&＃61; &＃39;__main__&＃39;:p &＃61; Process(target&＃61;func)p.start()p.name &＃61; &＃39;alex&＃39;print(&＃39;可以查看子进程的pid&＃39;,p.pid)print(&＃39;可以查看子进程的名字&＃39;, p.name)print(&＃39;子进程是不是守护进程&＃39;, p.daemon) false


from multiprocessing import Process
import time
def func():time.sleep(3.1)print(&＃39;this is son process&＃39;)
if __name__ &＃61;&＃61; &＃39;__main__&＃39;:p &＃61; Process(target&＃61;func)p.daemon &＃61; True #必须在start之前设置p.start()time.sleep(3)print(&＃39;this is parent process&＃39;)
#守护进程会随着主进程的结束而结束.


from multiprocessing import Process
import time
def func1():print(&＃39;这里是孙子&＃39;)
def func():p &＃61; Process(target&＃61;func1)p.start()time.sleep(5)print(&＃39;这里是儿子哦&＃39;)
if __name__ &＃61;&＃61; &＃39;__main__&＃39;:p &＃61; Process(target&＃61;func)p.daemon &＃61; True # 将p进程设置为守护进程,必须要在start之前设置p.start()time.sleep(1)print(&＃39;这是爸爸&＃39;)
# 守护进程&＃xff1a;不允许开启子进程


from multiprocessing import Process
import time
import sys
def func():print(sys.modules[__name__].__name__)
print(123)
if __name__ &＃61;&＃61; &＃39;__main__&＃39;:p &＃61; Process(target&＃61;func)
#当程序运行到这一句时, 会把全部内容复制放在一块内存中,p.start() # 开启一个子进程print(&＃39;hahhh&＃39;)
# 程序从上往下执行, 先打印一个123, 然后主程序执行到p &＃61; process() 会把全部的内容复制到一块内存中,
# 然后p.start开始运行, 程序从上到下一次执行, 运行到if语句时结束.因为此时的__name &＃61; _mp_main_,条件不成立所以打印了两次123.


from multiprocessing import Process
import socket
sk &＃61; socket.socket()
sk.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
sk.bind((&＃39;127.0.0.1&＃39;,9990))
sk.listen(5)
def talk(conn):while 1:try:msg &＃61; conn.recv(1024).decode(&＃39;utf-8&＃39;)if not msg:breakconn.send(msg.upper().encode(&＃39;utf-8&＃39;))except Exception:break
if __name__ &＃61;&＃61; &＃39;__main__&＃39;:while 1: #(在此加上while, 可以实现一个服务器与多个客户端进行通信)conn, addr &＃61; sk.accept()p &＃61; Process(target&＃61;talk, args &＃61; (conn, ))p.start()

import socket
sk &＃61; socket.socket()
sk.connect((&＃39;127.0.0.1&＃39;, 9990))
while 1:content &＃61; input(&＃39;请输入内容>>>&＃39;)if not content:continuesk.send(content.encode(&＃39;utf-8&＃39;))msg &＃61; sk.recv(1024).decode(&＃39;utf-8&＃39;)print(msg)