Python. Threading

Question

Привет, У меня есть сервер/клиентская модель с использованием модуля SocketServer. Задача сервера - получить тестовое имя от клиентов и запустить тест. тест запускается с использованием модуля подпроцесса. Я хотел бы, чтобы сервер продолжал отвечать на запросы клиентов и любые новые задания, которые нужно укладывать в список или очередь, и запускать один за другим, единственное ограничение, которое у меня есть, - это не запускать тест на сервере, если только его выполнение не выполняется.

Благодаря

Answer 1

Вы можете использовать модуль

multiprocessing

для запуска новых процессов. На стороне сервера у вас будет переменная, которая ссылается на текущий текущий процесс. Вы все еще можете запускать и принимать запросы SocketServer и сохранять их в списке. Каждую секунду (или все, что вы хотите), в другом потоке, вы должны проверить, мертв ли ​​текущий процесс или нет, вызвав isAlive(). Если он мертв, просто просто запустите следующий тест в списке.

Другой способ сделать это (лучше), это то, что в третьем потоке (тот, который проверяет) вы вызываете .join() из процесса, чтобы он вызывал только следующую строку кода после текущего процесса мертв. Таким образом, вам не нужно постоянно проверять каждую секунду или что-то еще, и это более эффективно.

Answer 2

Что вы можете сделать, это:

1. Получить тест имя в сокет сервера, поместите его в Queue
2. В отдельном потоке, прочитать имена тестов из очереди по одному
3. Выполните процесс и дождитесь его завершения с помощью communicate()
4. Продолжайте опрос Очередь для новых тестов, повторите шаги 2, 3, если доступны тестовые имена
5. Между тем сервер продолжает получать и ввод тестовых имен в очередь