-3

我最近正在使用 Python 学习多处理。我学到的是我们在 Python 中使用多处理模块来实现并行性,这意味着进程是同时执行的。

但是为什么下面的代码显示四个进程的启动时间之间存在几毫秒的差异?

from multiprocessing import Process
import os, time, datetime, random, tracemalloc

tracemalloc.start()
children = 4    # number of child processes to spawn
maxdelay = 6    # maximum delay in seconds

def status():
    return ('Time: ' + 
        str(datetime.datetime.now().time()) +
        '\t Malloc, Peak: ' +
        str(tracemalloc.get_traced_memory()))

def child(num):
    delay = random.randrange(maxdelay)
    print(f"{status()}\t\tProcess {num}, PID: {os.getpid()}, Delay: {delay} seconds...")
    time.sleep(delay)
    print(f"{status()}\t\tProcess {num}: Done.")

if __name__ == '__main__':
    print(f"Parent PID: {os.getpid()}")
    for i in range(children):
        proc = Process(target=child, args=(i,))
        proc.start()

下面是输出:

Parent PID: 16048
Time: 09:52:47.014906    Malloc, Peak: (228400, 240036)     Process 0, PID: 16051, Delay: 1 seconds...
Time: 09:52:47.016517    Malloc, Peak: (231240, 240036)     Process 1, PID: 16052, Delay: 4 seconds...
Time: 09:52:47.018786    Malloc, Peak: (231616, 240036)     Process 2, PID: 16053, Delay: 3 seconds...
Time: 09:52:47.019398    Malloc, Peak: (232264, 240036)     Process 3, PID: 16054, Delay: 2 seconds...

Time: 09:52:48.017104    Malloc, Peak: (228434, 240036)     Process 0: Done.
Time: 09:52:49.021636    Malloc, Peak: (232298, 240036)     Process 3: Done.
Time: 09:52:50.022087    Malloc, Peak: (231650, 240036)     Process 2: Done.
Time: 09:52:51.020856    Malloc, Peak: (231274, 240036)     Process 1: Done.

为什么进程的开始时间不同?这不违反并行的定义吗?

4

1 回答 1

1

为了补充@chepner 所说的内容,您将在for循环中一次启动一个进程,因此它们将按顺序启动。这与说它们没有并行运行不同。

事实上,它们并行执行的,因为进程的结束顺序与它们启动时的顺序不同。如果它们是按顺序执行的,它们也将以您启动它们的顺序结束。

相反,这些过程完全按照它们的延迟量结束。进程 0 有 1 秒的延迟,所以它首先结束。进程 3 有 2 秒的延迟,秒结束。进程 2 有 3 秒的延迟,第三个结束。最后,进程 1 有 4 秒的延迟,第四个结束。这表明它们实际上是并行运行的。

于 2021-01-04T13:51:19.630 回答