Python-сообщество

gelius · Фев. 2, 2023 17:48:56

Такой код запускает 32 пинг завершающихся в разное время,

 import random
import subprocess
from threading import Thread
results = []
start_processes = 32
def run_command(count, result_storage):
    cmd = str(subprocess.check_output(['ping', '-c', f'{body}', 'google.' + 'com'], text=True))
    result_storage.append(cmd)
threads = []
for _ in range(start_processes):
    ch = random.choices('1234567890', k=2)
    body = (''.join(ch))
    print(body)
    t = Thread(target=run_command, args=[body, results])
    t.start()
    threads.append(t)
for t in threads:
    t.join()

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

py.user.next · Фев. 3, 2023 01:19:02

Сделай один контролирующий процесс и регистрируй в нём запускающиеся процессы. Он же и проверяет их количество в цикле и выполняет дозапуски.

gelius · Фев. 3, 2023 10:07:18

py.user.next
Сделай один контролирующий процесс и регистрируй в нём запускающиеся процессы. Он же и проверяет их количество в цикле и выполняет дозапуски.

Есть пример такого кода?
Еще варианты?

Rodegast · Фев. 3, 2023 12:26:33

Первая счылка в гугле. https://docs-python.ru/standart-library/modul-threading-python/poluchenie-obschih-svedenij-potokah-modul-threading/

С дураками и сектантами не спорю, истину не ищу.
Ели кому-то правда не нравится, то заранее извиняюсь.

gelius · Фев. 3, 2023 16:21:04

Rodegast
Первая счылка в гугле. https://docs-python.ru/standart-library/modul-threading-python/poluchenie-obschih-svedenij-potokah-modul-threading/

Но не понятен, код такой 12 едениц пишет в консоль:

 import threading, time
def worker(firefox):
    time, sleep(3)
for _ in range(12):
    thread = threading.Thread(target=worker)
    thread = threading.active_count()
    n_thread = threading.active_count()
    print (n_thread)

Такой скрипт выполняется и виден в диспетчере задач до завершения последнего пинг:

 import random
import subprocess
from threading import Thread
results = []
start_processes = 32
def run_command(count, result_storage):
    cmd = str(subprocess.check_output(['ping', '-c', f'{body}', 'google.' + 'com'], text=True))
    result_storage.append(cmd)
threads = []
for _ in range(start_processes):
    ch = random.choices('1234567890', k=2)
    body = (''.join(ch))
    print(body)
    t = Thread(target=run_command, args=[body, results])
    t.start()
    threads.append(t)
for t in threads:
    t.join()

Может быть для python subprocess есть функционал подобный cron?

Отредактировано gelius (Фев. 5, 2023 10:24:14)

Python-сообщество

Уведомления

#1 Фев. 2, 2023 17:48:56

определенное количество одновременно запущенных процессов

#2 Фев. 3, 2023 01:19:02

определенное количество одновременно запущенных процессов

#3 Фев. 3, 2023 10:07:18

определенное количество одновременно запущенных процессов

#4 Фев. 3, 2023 12:26:33

определенное количество одновременно запущенных процессов

#5 Фев. 3, 2023 16:21:04

определенное количество одновременно запущенных процессов

Board footer