запуск двух сценариев одновременно из основного сценария, когда каждый сценарий содержит несколько потоков в python

Question

Я хочу запустить два или более python сценария одновременно из master script. В каждом из этих сценариев уже есть потоки, которые работают параллельно. Например, я запускаю

script1.py

if __name__ == '__main__':
    pid_vav = PID_VAV('B2')
    t1 = threading.Thread(target=pid_vav.Controls)
    t1.daemon = False
    t1.start()
    t2 = threading.Thread(target=pid_vav.mqttConnection)
    t2.daemon = False
    t2.start()

script2.py

if __name__ == '__main__':
    pid_vav = PID_VAV('B4')
    t1 = threading.Thread(target=pid_vav.Controls)
    t1.daemon = False
    t1.start()
    t2 = threading.Thread(target=pid_vav.mqttConnection)
    t2.daemon = False
    t2.start()

Я запускаю это script1.py и script2.py отдельно. Единственная разница - это параметр, который я передаю классу. Возможно ли иметь главный сценарий таким образом, чтобы, если бы я просто запустил его, оба этих сценария были запущены?

Спасибо

Answer 1

Если вы хотите запустить 2 сценария из основного сценария, вы можете использовать следующий метод. Это поможет вам запустить оба сценария как поток, и поток также может создавать разные потоки на основе вызываемых сценариев. Вы можете даже заставить Сценарии работать независимо.

import subprocess

pid1 = subprocess.Popen([sys.executable, "script1.py"]) 
pid2 = subprocess.Popen([sys.executable, "script2.py"]) 

Answer 2

Предполагая, что вы хотите, чтобы вывод обоих сценариев отображался при запуске мастер-сценария.
Вы можете использовать модуль subprocess для вызова файла python и использовать threading модуль для запуска отдельных потоков

from threading import Thread
import subprocess

t1 = Thread(target=subprocess.run, args=(["python", "script1.py"],))
t2 = Thread(target=subprocess.run, args=(["python", "script2.py"],))

t1.start()
t2.start()

t1.join()
t2.join()

Answer 3

Да, из c.

script_master.py:

from os import system
system('start script1.py && start script2.py')

Но я думаю, вы можете использовать этот код:

script_together.py:

if __name__ == '__main__':
    todo=[]

    todo.append(threading.Thread(target=lambda: PID_VAV('B2').Controls, daemon=False))
    todo.append(threading.Thread(target=lambda: PID_VAV('B4').mqttConnection, daemon=False))
    for th in todo:
        th.start()
    for th in todo:
        th.join()

Answer 4

Если вы счастливы, что код для обоих вживую находится в одном файле, вы можете использовать многопроцессорную обработку для одновременного запуска их на разных ядрах ЦП.

import multiprocessing as mp
from threading import Thread

def start_process(pid_vav_label):
    pid_vav, threads = PID_VAV(pid_vav_label), []
    threads.append(Thread(target=pid_vav.Controls))
    threads.append(Thread(target=pid_vav.mqttConnection))
    for thread in threads:
        thread.start()
    # Join if necessary
    for thread in threads:
        thread.join()

if __name__ == '__main__':
    processes = []
    for label in ['B2', 'B4']:
        processes.append(mp.Process(target=start_process, args=(label,)))
        processes[-1].start()
    # Again, can join if necessary
    for process in processes:
        process.join()