多进程

迷南。 2021-11-11 15:16 355阅读 0赞

## 多进程概述 ##

多进程代码：
    from multiprocessing import Process
    方法：
        进程对象.start()——开启一个子进程
        进程对象.join()——感知一个子进程的结束
        进程对象.terminamte()——结束一个子进程
        进程对象.is_alive()——查看某个子进程是否还在运行
    属性：
        进程对象.name——进程名
        进程对象.pid——进程号
        进程对象.daemon——值为True时，标识新的子进程是一个守护进程
    守护进程：
        守护进程：随着主进程代码的执行结束而结束
        必须要写在start之前
    加锁：
        from multiprocessing import Lock
        l = Lock()
        l.acquire()     # 拿钥匙
        # 会造成数据不安全的操作
        l.release()     # 还钥匙

## 创建进程有两种方法： ##

### 1.使用process模块创建进程 ###

在一个python进程中开启子进程，start方法和并发效果。

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

from multiprocessing import Process
    import os
    import time
    def fun(arg1,arg2):
        print('*'*arg1)
        time.sleep(3)
        print('*'*arg2)
    if __name__ == '__main__':
        p_lst=[]
        for i in range(10):
            p = Process(target=fun,args=(i+1,i+5))
            p_lst.append(p)
            p.start()
        [p.join() for p in p_lst]
        print('执行完毕！！！')

process

###  2.继承Process类的形式开启进程 ###

需要注意的点：

如果需要传参，那么在类中定义init方法是记得写入super().\_\_init\_\_()来继承父类中其他属性，否则会报错

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

from multiprocessing import Process
    import os
    class MyProcess(Process):
        def __init__(self,name,age):
            super().__init__()
            self.name = name
            self.age = age
        def run(self):
            print(111)
            print(self.name)
            print(self.age)
    if __name__ == '__main__':
        p = MyProcess('Mr.Feng',18)
        p.start()

继承类方法创建子进程

###  进程之间的数据隔离 ###

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

from multiprocessing import Process
    import os
    def func():
        global n
        n = 0
        print('pid : {}'.format(os.getpid()),n)
    
    if __name__ == '__main__':
        n = 100
        p = Process(target=func)
        p.start()
        p.join()
        print(os.getpid(),n)
    # 几个数据之间如果不用特殊方法无法实现变量共享

数据隔离

通过多进程实现server并发

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

import socket
    from multiprocessing import Process
    def server(conn):
        info = '你好'.encode('utf-8')
        conn.send(info)
        msg = conn.recv(1024).decode('utf-8')
        print(msg)
        conn.close()
    
    
    if __name__ == '__main__':
    
        sk = socket.socket()
        sk.bind(('127.0.0.1',8080))
        sk.listen(0)
    
        while True:
            conn, addr = sk.accept()
            p = Process(target=server,args=(conn,))
            p.start()
    
        sk.close()

server

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

import socket
    sk = socket.socket()
    sk.connect(('127.0.0.1',8080))
    
    while True:
        msg = sk.recv(1024).decode('utf-8')
        print(msg)
        info = input('>>')
        if info == 'q':break
        sk.send(info.encode('utf-8'))
    
    
    sk.close()

client1

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

import socket
    sk = socket.socket()
    sk.connect(('127.0.0.1',8080))
    
    while True:
        msg = sk.recv(1024).decode('utf-8')
        print(msg)
        info = input('>>')
        if info == 'q':break
        sk.send(info.encode('utf-8'))
    
    
    sk.close()

client2

### 守护进程 ###

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

from multiprocessing import Process
    import time
    def func():
        while True:
            time.sleep(0.2)
            print('我还活着')
    def func2():
        print('in func2 start')
        time.sleep(8)
    if __name__ == '__main__':
        p = Process(target=func)
        p.daemon = True     # 守护进程：主进程结束，子进程结束
        p.start()
        p1 = Process(target=func2)
        p1.start()
        i = 0
        while i<5:
            print('我是socketserver')
            time.sleep(1)
            i+=1
    # 守护进程会随着主进程的代码结束而结束
    # 在主进程内结束一个子进程p.terminate()
        # 结束一个进程不是在执行方法之后立即失效，需要一个操作系统响应的过程
    # 检验一个进程是否还活着的状态p.is_alive()
    # p.name p.pid 这个进程的名字和进程号

守护进程

### 进程锁 ###

在修改文件时必须加设备锁

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

from multiprocessing import Process
    import json
    import time
    from multiprocessing import Lock
    
    
    def show(arg):
        with open('tiket') as f:
            dic = json.load(f)
            print('余票:{}     '.format(dic['ticket']),arg)
    def buy(arg,lock):
        lock.acquire()      # 拿到钥匙进入程序
        with open('tiket') as f:
            dic = json.load(f)
            time.sleep(0.1)
        if dic['ticket']>0:
            dic['ticket'] -= 1
            print('\033[32m{}买到票了\033[0m'.format(arg))
        else:
            print('\033[31m{}没买到票\033[0m'.format(arg))
        with open('tiket','w') as f:
            json.dump(dic,f)
        lock.release()      # 归还钥匙
    if __name__ == '__main__':
        for i in range(10):
            p = Process(target=show,args=(i,))
            p.start()
        lock = Lock()
        for i in range(10):
            p = Process(target=buy,args=(i,lock))
            p.start()

设备锁

###  信号量 ###

在规定能同事访问某段代码的进程数

![ContractedBlock.gif][] ![ExpandedBlockStart.gif][]

from multiprocessing import Process
    from multiprocessing import Semaphore
    import time
    import random
    
    def ktv(i,sem):
        sem.acquire()
        print('%s走进KTV' % i)
        time.sleep(random.randint(10,20))
        sem.release()
    if __name__ == '__main__':
        sem = Semaphore(4)
        for i in range(20):
            p = Process(target=ktv,args=(i,sem))
            p.start()

信号量

转载于:https://www.cnblogs.com/Mr-Feng/p/10893172.html

[ContractedBlock.gif]: https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif
[ExpandedBlockStart.gif]: /images/20211109/14bc5209b1464516910299755bb072b7.png

发表评论取消回复

表情：

评论列表（有 0 条评论，355人围观）

还没有评论，来说两句吧...

相关阅读

相关 684-进程&进程控制&多进程&进程控制块

什么是进程？进程是由程序变换而来，介绍进程时，需要先从程序说起。（1）当程序没有运行时当程序没有被运行时，该程序（可执行文件）只是存放在硬盘上的静态数据，与

港控/mmm°/ 2022年09月16日 06:08/ 0 赞/ 210 阅读

相关编写多进程程序 --多进程编程

实验目的通过编写多进程程序，熟练掌握fork()、exec()、wait()和waitpid()等函数的使用，进一步理解在Linux中多进程编程的步骤。实验内容

客官°小女子只卖身不卖艺/ 2022年08月01日 14:50/ 0 赞/ 224 阅读

相关多进程通信

多进程：首先，先来讲一下fork之后，发生了什么事情。由fork创建的新进程被称为子进程（child process）。该函数被调用一次，但返回两次。两次返回的区别

我不是女神ヾ/ 2022年05月16日 09:00/ 0 赞/ 199 阅读

相关 python多进程

互联网上介绍多进程的文章很多，比如[Python多进程 - 实现多进程的几种方式][Python_ -]、[python多进程并发][python]、[多进程][Link 1]

ゝ一世哀愁。/ 2022年03月19日 17:59/ 0 赞/ 251 阅读

相关 Python多进程

Python多进程方面涉及到的模块主要包括： subprocess: 可以在当前程序中执行其他程序或命令 mmap：提供一种基于内存的进程间通信机制 mul

╰+攻爆jí腚メ/ 2022年01月28日 23:17/ 0 赞/ 327 阅读

相关多进程2

进程之间数据不共享,但是共享同一套文件系统,所以访问同一个文件,或打印同一个终端,是没有问题的加锁是将程序由并发转换为串行,牺牲运行效率,避免竞争加锁可以保证多个进程修

淩亂°似流年/ 2021年12月20日 08:17/ 0 赞/ 221 阅读

相关多进程

多进程概述多进程代码： from multiprocessing import Process 方法：进程对象.start()

迷南。/ 2021年11月11日 15:16/ 0 赞/ 356 阅读

相关多进程实践

from time import ctime,sleep import multiprocessing 导入进程相关的模块定义说和写的方法 d

柔情只为你懂/ 2021年09月29日 13:46/ 0 赞/ 300 阅读

相关 Python多进程

[引用地址https://www.cnblogs.com/kaituorensheng/p/4445418.html][https_www.cnblogs.com_kaituo

川长思鸟来/ 2021年09月20日 14:30/ 0 赞/ 332 阅读

相关多进程编程

多进程编程概念程序: 计算机中存储的二进制代码进程: 计算机中运行的程序多进程: 多个进程同时运行进程的创建 Linux环境下执行实例

今天药忘吃喽~/ 2021年09月17日 06:30/ 0 赞/ 411 阅读