Что такое функция wait()?

Wait() в контексте Python multiprocessing является методом объекта Process или Popen, который приостанавливает выполнение текущего родительского процесса до тех пор, пока дочерний процесс, на котором вызван wait(), не завершится.

Основные особенности и применение:

• Синхронизация: Обеспечивает синхронизацию между родительским и дочерним процессами, гарантируя, что родительский процесс не продолжит выполнение до завершения дочернего.
• Получение статуса завершения: Возвращает код завершения дочернего процесса. Код 0 обычно означает успешное завершение, а ненулевое значение – ошибку.
• Блокирующее поведение: Вызов wait() является блокирующим. Это означает, что текущий процесс будет ждать неопределенно долго, пока дочерний не завершится, если не указан тайм-аут.
• Тайм-аут: Может принимать необязательный аргумент timeout, указывающий максимальное время ожидания в секундах. Если дочерний процесс не завершается в течение указанного времени, возникает исключение TimeoutExpired.

import multiprocessing
import time

def worker():
    // Имитация длительной работы
    time.sleep(3)
    print("Дочерний процесс завершен.")
    return 0 // Успешное завершение

if __name__ == "__main__":
    process = multiprocessing.Process(target=worker)
    process.start() // Запуск дочернего процесса

    print("Ожидание завершения дочернего процесса...")
    exit_code = process.wait() // Ожидание завершения и получение кода выхода
    print(f"Дочерний процесс завершился с кодом: {exit_code}")

    // Пример с тайм-аутом
    process_with_timeout = multiprocessing.Process(target=worker)
    process_with_timeout.start()
    try:
        exit_code_timeout = process_with_timeout.wait(timeout=1) // Максимальное ожидание 1 секунда
        print(f"Дочерний процесс с таймаутом завершился с кодом: {exit_code_timeout}")
    except multiprocessing.TimeoutError:
        print("Дочерний процесс с таймаутом не завершился вовремя.")
        process_with_timeout.terminate() // Завершение процесса, если таймаут истек

import subprocess

// Пример использования wait() в subprocess
process = subprocess.Popen(["ls", "-l"])
return_code = process.wait() // Ожидание завершения и получение кода возврата
print(f"Процесс завершился с кодом: {return_code}")

Сравнение с join():

В контексте multiprocessing wait() и join() могут казаться похожими. Однако wait() используется для получения кода завершения, в то время как join() просто ожидает завершения без возврата статуса. В subprocess, wait() является основным методом для ожидания завершения запущенного внешнего процесса и получения его кода возврата.