专栏首页python3进程(一)

进程(一)

在Python中进程操作

multiprocessm模块

multiprocess.process模块

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

方法介绍

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

属性方法

 1 import time
 2 from mulitiprocessing import Process
 3 
 4 def func(name):
 5     print('hello',name)
 6     time.sleep(1)
 7 
 8 if __name__ == '__main__':
 9     p_lst = []
10     for i in range(5):
11         p = Process(target=func,args=('yan',))
12         p.start()
13         p_lst.append(p)
14         p.join()
15         #for p in p_lst:p.join()
16     print('父进程在执行')

开启多个进程同事运行,join方法()

一些其他开启的进程方法,比如继承:

 1 import os
 2 from mulitiprocessing import Process
 3 
 4 class MyProcess(Process):
 5     def __init__(self,name):
 6         super().__init__()
 7         self.name = name
 8     def func(self):
 9         print(os.getpid)
10         print('%s 正在和漂亮妹子聊天' %self.name)
11 
12 p1 = MyProcess('yan')
13 p2 = MyProcess('chou')
14 p3 = MyProcess('da')
15 
16 p1.start()
17 p2.start()
18 p3.start()
19 
20 p1.join()
21 p2.join()
22 p3.join()
23 print('主进程')

进程实现继承

进程之间的数据隔离问题

import os 
from multiprocessing import Process

def work():
    global n
    n = 0
    print('子进程内:',n)

if __name__ == '__main__':
    n = 100
    p = Process(target = work)
    p.start()
    print('主进程内:',n)

View Code

守护进程

含义:会随着主进程的结束而结束

主进程创建守护进程的作用;

  一、守护进程会在主进程代码执行结束后就终止

  二、守护进程内无法再开启子进程,否则抛出异常:

注意:进城之间是互相独立的,主进程代码运行结束,守护进程随即结束

 1 import time
 2 import os 
 3 from multiprocessing import Process
 4 
 5 class MyProcess(Process):
 6     def __init__(self,person):
 7         super().__init__()
 8         self.person = person
 9      def func(self):
10         print(os.getpid(),self.name)
11         print('%s正在和妹子聊天' %self.person)
12 
13 p = MyProcess('大为')
14 p.daemon = True  #一定要在p.start()前设置p为守护进程,禁止p创建子进程,并且父进程代执行结束,p即终止运行
15 p.start()
16 time.sleep(10)
17 print('主进程')

开启守护进程

 1 import time
 2 from multiprocessing import Process
 3 
 4 def func1():
 5     while True:
 6         time.sleep(0.2)
 7         print('我还活着')
 8 
 9 def func2():
10     time.sleep(2)
11     print('in func2 finihsh')
12 
13 if __name__ == '__main__':
14     p1 = Process(target = func1)
15     p1.daemon = True
16     p1.start()
17     p2 = Process(target = func2)
18     p2.start()
19     i = 0
20     while i<3:
21         print('我是socket server')
22         time.sleep(1)
23         i +=1

主进程代码执行结束守护进程立即结束

socket聊天并发实例

 1 import socket
 2 from multiprocessing import Process
 3 
 4 def server(conn):
 5     ret = '你好'.encode('utf-8')
 6     conn.send(ret)
 7     msg = conn.recv(1024).decode('utf-8')
 8     print(msg)
 9     conn.close()
10 if __name == '__main__':
11     sk = socket.socket()
12     sk.bind(('127.0.0.1',8080))
13     sk.listen()
14     whlie True:
15         conn,addr = sk.accpet()
16         p = Process(target = server,args = (conn,))
17         p.start()
18     sk.close()

socket端

 1 import socket
 2 sk = socket.socket()
 3 sk.connect(('127.0.0.1',8080))
 4 msg = sk.recv(1024).decode('utf-8')
 5 print(msg)
 6 
 7 msg2 = input('>>>').encode('utf-8')
 8 sk.send(msg2)
 9 
10 sk.close()

client

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • python之线程、进程

        从列表中取一个数据,相当于是复制了一份列表中的数据,列表中的元数据并没有被改动

    py3study
  • python中if,for,while语

    for 变量 in range(10): 循环需要执行的代码 练习: #求1~100之间所有偶数之和

    py3study
  • Python 多进程 多线程数据共享

    py3study
  • day37(多进程)- 多进程、守护进程、进程锁

    # obj.start() 实际上是用的 run() 方法 # 但是对象不能直接调用 run() 方法 # 直接调用就立即执行,成了单线程 ...

    少年包青菜
  • python3--队列Queue,管道Pipe,进程之间的数据共享,进程池Pool,回调函数callback

    既打印了主进程put的值,也打印了子进程put的值,在进程中使用队列可以完成双向通信

    py3study
  • python高阶教程-上下文管理器

    本文由腾讯云+社区自动同步,原文地址 http://blogtest.stackoverflow.club/book/senior_python/context...

    羽翰尘
  • python3–循环语句

    老七Linux
  • Numpy教程第1部分 - 阵列简介(常用基础操作总结)

    【导读】这里是numpy教程的基础部分,涵盖了使用numpy的ndarrays执行数据操作和分析的一些操作。众所周知,Numpy是Python中最基本和最强大的...

    WZEARW
  • 第四冠!腾讯AI「绝艺」斩获世界智能围棋公开赛冠军

    ? 导语:腾讯围棋AI「绝艺」世界大赛再夺金,三年四冠,砥砺前行! ? 中国围棋协会主办的2019「中信建投证券杯」世界智能围棋公开赛今天在山东日照落幕。由腾...

    腾讯技术工程官方号
  • Numpy中的转置轴对换

    转置是重塑的一种特殊形式。转置返回源数组的视图,源数组和对源数组进行转置操作后返回的数组指向的是同一个地址。Numpy中有三种方式能够对数组进行转置操作:

    触摸壹缕阳光

扫码关注云+社区

领取腾讯云代金券