zoukankan      html  css  js  c++  java
  • Python Process创建进程的(2种方法)

    Python 在 multiprocessing 模块下提供了 Process 来创建新进程。与 Thread 类似的是,使用 Process 创建新进程也有两种方式:

    1. 以指定函数作为 target,创建 Process 对象即可创建新进程。
    2. 继承 Process 类,并重写它的 run() 方法来创建进程类,程序创建 Process 子类的实例作为进程。


    Process 类也有如下类似的方法和属性:

            run():重写该方法可实现进程的执行体。

            start():该方法用于启动进程。

            join([timeout]):该方法类似于线程的 join() 方法,当前进程必须等待被 join 的进程执行完成才能向下执行。

            name:该属性用于设置或访问进程的名字。

            is_alive():判断进程是否还活着。

            daemon:该属性用于判断或设置进程的后台状态。

            pid:返回进程的 ID。

            authkey:返回进程的授权 key。

            terminate():中断该进程。

    import multiprocessing
    import 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('主进程执行完成!')

    可以发现和之前创建多线程似乎是同样的过程和方法,只是这里用到的是  multiprocessing.Process ,运行上面程序,可以看到程序中运行了三个进程,一个主进程和程序启动的两个子进程。由于程序中调用了 mp2.join(),因此主进程必须等 mp2 进程完成后才能向下执行。

    继承Process类创建子进程

    继承 Process 类创建子进程的步骤如下:

            1.定义继承 Process 的子类,重写其 run() 方法准备作为进程执行体。

            2.创建 Process 子类的实例。

            3.调用 Process 子类的实例的 start() 方法来启动进程

    import multiprocessing
    import os
    class 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('主进程执行完成!')

    通常,推荐使用第一种方式来创建进程,因为这种方式不仅编程简单,而且进程直接包装 target 函数,具有更清晰的逻辑结构。

  • 相关阅读:
    刘墉写给女儿的忠告
    HTML & CSS 小总结
    [LeetCode] 151. Reverse Words in a String 翻转字符串中的单词
    [LeetCode] 340. Longest Substring with At Most K Distinct Characters 最多有K个不同字符的最长子串
    [LeetCode] 127. Word Ladder 单词阶梯
    [LeetCode] 300. Longest Increasing Subsequence 最长递增子序列
    [LeetCode] 354. Russian Doll Envelopes 俄罗斯套娃信封
    [LeetCode] 218. The Skyline Problem 天际线问题
    [LeetCode] 407. Trapping Rain Water II 收集雨水 II
    [LeetCode] 309. Best Time to Buy and Sell Stock with Cooldown 买卖股票的最佳时间有冷却期
  • 原文地址:https://www.cnblogs.com/jzxs/p/11428467.html
Copyright © 2011-2022 走看看