谁懂啊!Python 多进程居然能写得又快又优雅,看完直接封神

import osprint('父进程（%s）开始执行' % os.getpid())# 开始fork一个子进程# 从这行代码开始，下面代码都会被两个进程执行pid = os.fork()print('进程进入：%s' % os.getpid())# 如果pid为0，表明子进程if pid == 0:    print('子进程，其ID为 (%s)， 父进程ID为 (%s)' % (os.getpid(), os.getppid()))else:    print('我 (%s) 创建的子进程ID为 (%s).' % (os.getpid(), pid))print('进程结束：%s' % os.getpid())

import multiprocessingimport os# 定义一个普通的action函数，该函数准备作为进程执行体def action(max):    for i in range(max):        print("(%s)子进程（父进程:(%s)）：%d" %             (os.getpid(), os.getppid(), i))if __name__ == '__main__':    # 下面是主程序（也就是主进程）    for i in range(100):        print("(%s)主进程: %d" % (os.getpid(), i))        if i == 20:            # 创建并启动第一个进程            mp1 = multiprocessing.Process(target=action,args=(100,))            mp1.start()            # 创建并启动第一个进程            mp2 = multiprocessing.Process(target=action,args=(100,))            mp2.start()            mp2.join()    print('主进程执行完成!')

import multiprocessingimport osclass MyProcess(multiprocessing.Process):    def __init__(self, max):        self.max = max        super().__init__()    # 重写run()方法作为进程执行体    def run(self):        for i in range(self.max):            print("(%s)子进程（父进程:(%s)）：%d" %                 (os.getpid(), os.getppid(), i))if __name__ == '__main__':    # 下面是主程序（也就是主进程）    for i in range(100):        print("(%s)主进程: %d" % (os.getpid(), i))        if i == 20:            # 创建并启动第一个进程            mp1 = MyProcess(100)            mp1.start()            # 创建并启动第一个进程            mp2 = MyProcess(100)            mp2.start()            mp2.join()    print('主进程执行完成!')

import multiprocessingimport osdef foo(q):    print('被启动的新进程: (%s)' % os.getpid())    q.put('Python')if __name__ == '__main__':    # 设置使用fork方式启动进程    multiprocessing.set_start_method('spawn')    q = multiprocessing.Queue()    # 创建进程    mp = multiprocessing.Process(target=foo, args=(q, ))    # 启动进程    mp.start()    # 获取队列中的消息     print(q.get())    mp.join()

import multiprocessingimport osdef foo(q):    print('被启动的新进程: (%s)' % os.getpid())    q.put('Python')if __name__ == '__main__':    # 设置使用fork方式启动进程，并获取Context对象    ctx = multiprocessing.get_context('fork')    # 接下来就可用Context对象来代替mutliprocessing模块了    q = ctx.Queue()    # 创建进程    mp = ctx.Process(target=foo, args=(q, ))    # 启动进程    mp.start()    # 获取队列中的消息     print(q.get())    mp.join()

import multiprocessingimport timeimport osdef action(name='default'):    print('(%s)进程正在执行，参数为: %s' % (os.getpid(), name))    time.sleep(3)if __name__ == '__main__':    # 创建包含4条进程的进程池    pool = multiprocessing.Pool(processes=4)    # 将action分3次提交给进程池    pool.apply_async(action)    pool.apply_async(action, args=('位置参数', ))    pool.apply_async(action, kwds={'name': '关键字参数'})    pool.close()    pool.join()

import multiprocessingimport timeimport os# 定义一个准备作为进程任务的函数def action(max):    my_sum = 0    for i in range(max):        print('(%s)进程正在执行: %d' % (os.getpid(), i))        my_sum += i    return my_sumif __name__ == '__main__':    # 创建一个包含4条进程的进程池    with multiprocessing.Pool(processes=4) as pool:        # 使用进程执行map计算        # 后面元组有3个元素，因此程序启动3条进程来执行action函数        results = pool.map(action, (50, 100, 150))        print('--------------')        for r in results:            print(r)

import multiprocessingdef f(q):    print('(%s) 进程开始放入数据...' % multiprocessing.current_process().pid)    q.put('Python')if __name__ == '__main__':    # 创建进程通信的Queue    q = multiprocessing.Queue()    # 创建子进程    p = multiprocessing.Process(target=f, args=(q,))    # 启动子进程    p.start()    print('(%s) 进程开始取出数据...' % multiprocessing.current_process().pid)    # 取出数据    print(q.get())  # Python    p.join()

import multiprocessingdef f(conn):    print('(%s) 进程开始发送数据...' % multiprocessing.current_process().pid)    # 使用conn发送数据    conn.send('Python')if __name__ == '__main__':    # 创建Pipe，该函数返回两个PipeConnection对象    parent_conn, child_conn = multiprocessing.Pipe()    # 创建子进程    p = multiprocessing.Process(target=f, args=(child_conn, ))    # 启动子进程    p.start()    print('(%s) 进程开始接收数据...' % multiprocessing.current_process().pid)    # 通过conn读取数据    print(parent_conn.recv())  # Python    p.join()

import multiprocessingimport timeclass Account:    # 定义构造器    def __init__(self, account_no, balance, lock):        # 封装账户编号、账户余额的两个成员变量        self.account_no = account_no        self._balance = balance        self.lock = lock    # 因为账户余额不允许随便修改，所以只为self._balance提供getter方法    def getBalance(self):        return self._balance    # 提供一个进程安全的draw()方法来完成取钱操作    def draw(self, draw_amount):        # 加锁        self.lock.acquire()        try:            # 账户余额大于取钱数目            if self._balance >= draw_amount:                # 吐出钞票                print(multiprocessing.current_process().name\                    + "取钱成功！吐出钞票:" + str(draw_amount))                time.sleep(0.001)                # 修改余额                self._balance -= draw_amount                print("\t余额为: " + str(self._balance))            else:                print(multiprocessing.current_process().name\                    + "取钱失败！余额不足！")        finally:            # 修改完成，释放锁            self.lock.release()# 定义一个函数来模拟取钱操作def draw(account, draw_amount):    print(account)    # 直接调用account对象的draw()方法来执行取钱操作    account.draw(draw_amount)if __name__ == '__main__':    lock = multiprocessing.RLock()    # 创建一个账户    acct = Account("1234567" , 900, lock)    # 模拟两个进程对同一个账户取钱    multiprocessing.Process(name='甲', target=draw , args=(acct , 800)).start()    multiprocessing.Process(name='乙', target=draw , args=(acct , 800)).start()    multiprocessing.Process(name='丙', target=draw , args=(acct , 800)).start()

# -*- coding: utf-8 -*-import multiprocessingimport requestsfrom time import ctimeimport jsondef syc_email(userID, userName):    """syc_email"""    print("Start synchronizing %s %s" % ("email", ctime()))    parameter = {"userId":userID,"userName":userName,"enterpriseId":"10330","flag":"sended"}    request_own = requests.put("https://xxxxxx.leadscloud.com/mail/receiveSendedAndRubbishMail", data=parameter)    data = request_own.json()    print(json.dumps(data, indent=4, sort_keys=True, ensure_ascii=False) )    print("接口调用已经返回结果，本次同步结束")dicts = {'1263':'13810078954','1294':'13810327625','1223':'18515934978','1295':'13911154792'}threads = []files = range(len(dicts))for userID, userName in dicts.items():    mp = multiprocessing.Process(target = syc_email, args = (userID, userName))    threads.append(mp)if __name__ == '__main__':    for p in files:        threads[p].start()    for p in files:        threads[p].join()    print('all end: %s' % ctime())

PS C:\Users\Administrator\Desktop> python .\multipreocess.pyStart synchronizing email Thu Mar 21 13:54:26 2019Start synchronizing email Thu Mar 21 13:54:26 2019Start synchronizing email Thu Mar 21 13:54:26 2019Start synchronizing email Thu Mar 21 13:54:26 2019{    "code": 1,    "data": 0,    "msg": "成功"}接口调用已经返回结果，本次同步结束{    "code": 1,    "data": 0,    "msg": "成功"}接口调用已经返回结果，本次同步结束{    "code": 1,    "data": 0,    "msg": "成功"}接口调用已经返回结果，本次同步结束{    "code": 1,    "data": 0,    "msg": "成功"}接口调用已经返回结果，本次同步结束all end: Thu Mar 21 14:03:22 2019

# -*- coding: utf-8 -*-from selenium import webdriverfrom time import sleepfrom time import ctimeimport multiprocessingdef start_browser(browser, time):    if browser == "chrome":        print("starting chrome browser now! %s" % ctime())  # 控制台打印当前时间         chrome_driver = webdriver.Chrome()        chrome_driver.get("http://www.baidu.com")        sleep(time)        chrome_driver.quit()    elif browser == "firefox":        print("starting firefox browser now! %s" % ctime())  # 控制台打印当前时间        fire_driver = webdriver.Firefox()        fire_driver.get("http://www.baidu.com")        sleep(time)        fire_driver.quit()    else:         print("starting ie browser now! %s" %ctime())  # 控制台打印当前时间        ie_driver = webdriver.Ie()        ie_driver.get("http://www.baidu.com")        sleep(time)        ie_driver.quit()#  定义字典参数        browser_dict = {"chrome": 3, "firefox": 4}#  定义空List用于存储进程start_browser_processing = []#  循环字典Key-Value，创建进程并加入到List中for browser, time in browser_dict.items():    processing_browser = multiprocessing.Process(target=start_browser, args=(browser, time))    start_browser_processing.append(processing_browser)if __name__ == '__main__':    for processing_browser in range(len(browser_dict)):        start_browser_processing[processing_browser].start()    for processing_browser in range(len(browser_dict)):        start_browser_processing[processing_browser].join()    print(u"全部结束 %s" % ctime())