python多进程（加入进程池）操作常见案例
本文实例讲述了python多进程（加入进程池）操作。分享给大家供大家参考，具体如下：
一、多进程复制多个文件
importmultiprocessing
importos
importtime
#复制文件，传入文件名
defcopy_file(old_file_name,old_name):
new_file_name='new_file'
new_name=old_name
ifnotos.path.exists(new_file_name):
os.makedirs(new_file_name)
withopen(old_file_name+'/'+old_name,'rb')asf:
file_content=f.read()
withopen(new_file_name+'/'+new_name,'wb')asf:
f.write(file_content)
if__name__=='__main__':
old_file_name='old_file'
name_list=os.listdir(old_file_name)
time_old=time.time()
fornameinname_list:
process=multiprocessing.Process(target=copy_file,args=(old_file_name,name))
process.start()
time_new=time.time()
print('执行时间：%f'%(time_new-time_old))
二、优化加入进程池，并显示复制进度：
importmultiprocessing
importos
importtime
#复制文件，传入文件名
defcopy_file(old_file_name,old_name,queue):
new_file_name='new_file'
new_name=old_name
ifnotos.path.exists(new_file_name):
os.makedirs(new_file_name)
withopen(old_file_name+'/'+old_name,'rb')asf:
file_content=f.read()
withopen(new_file_name+'/'+new_name,'wb')asf:
f.write(file_content)
queue.put(new_file_name)
if__name__=='__main__':
old_file_name='old_file'#存放文件的文件名
name_list=os.listdir(old_file_name)#取出所有文件的文件名
queue=multiprocessing.Manager().Queue()#创建队列对象，用于计算复制完成百分比
po=multiprocessing.Pool(3)#创建线程池
time_old=time.time()#用于计算花费时间
fornameinname_list:
po.apply_async(copy_file,(old_file_name,name,queue))
po.close()
index=0
whileTrue:
index+=1
queue.get()
print('\r以保存%.2f%%'%((index/len(name_list))*100),end='')
ifindex==len(name_list):
break
time_new=time.time()
print('执行时间：%f'%(time_new-time_old))
三、多进程聊天器：
importmultiprocessing
importsocket
importthreading
#需求：
#1.主进程创建一个TCPconnect
#2.主进程connect后创建进程开启一个新的Socketconnect
#3.进程里创建线程不断的接收和提示发送消息
#有连接时新创建一个进程处理聊天
defspeak_send(tcp_msg):
whileTrue:
test=input('请输入要发送的消息')
tcp_msg.send(test.encode('utf-8'))
defspeak_rec(tcp_msg):
whileTrue:
print(tcp_msg.recv(1024).decode('gbk'))
#开启的进程聊天
defspeak_process(tcp_sock,tcp_msg,ip):
print('开启进程')
#5.开线程循环接收消息
msg_rec=threading.Thread(target=speak_rec,args=(tcp_msg,))
#print(tcp_msg.recv(1024).decode('gbk'))
#6.开线程循环发送消息
msg_send=threading.Thread(target=speak_send,args=(tcp_msg,))
msg_rec.start()
msg_send.start()
msg_rec.join()
msg_send.join()
#7.关闭
#tcp_msg.close()
defmain():
#1创建TCP对象
tcp_sock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
#2.绑定ip和端口
tcp_sock.bind(('',9999))
#3.改主动为被动
tcp_sock.listen(128)
#4.accept接收msg和ip
whileTrue:
tcp_msg,ip=tcp_sock.accept()
process=multiprocessing.Process(target=speak_process,args=(tcp_sock,tcp_msg,ip))
process.start()
if__name__=='__main__':
main()
更多关于Python相关内容感兴趣的读者可查看本站专题：《Python进程与线程操作技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》、《Python+MySQL数据库程序设计入门教程》及《Python常见数据库操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。