Запуск множества потоков одновременно с Python
Я пытаюсь запустить множество потоков (100 из них) одновременно в цикле for и получить общее время, необходимое для их выполнения с помощью Python.
Сначала я вручную создал 8 потоков и без проблем запустил их одновременно.
A1 = threading.Thread(target=TypeA)
A2 = threading.Thread(target=TypeA)
A3 = threading.Thread(target=TypeA)
A4 = threading.Thread(target=TypeA)
B1 = threading.Thread(target=TypeB)
B2 = threading.Thread(target=TypeB)
B3 = threading.Thread(target=TypeB)
B4 = threading.Thread(target=TypeB)
programStartTime = time.time()
A1.start()
A2.start()
A3.start()
A4.start()
B1.start()
B2.start()
B3.start()
B4.start()
A1.join()
A2.join()
A3.join()
A4.join()
B1.join()
B2.join()
B3.join()
B4.join()
programEndTime = time.time()
totalProgramTime = programEndTime - programStartTime
Переменная totalProgramTime составляла около 2 секунд, а время выполнения каждого потока было одинаковым.
Потом я захотел создать 100 потоков.
threads = {}
for i in range(50):
threads[i] = threading.Thread(target=TypeA)
for i in range(50, 100):
threads[i] = threading.Thread(target=TypeB)
programStartTime = time.time()
for i in range(100):
threads[i].start()
threads[i].join()
programEndTime = time.time()
totalProgramTime = programEndTime - programStartTime
На этот раз потоки работали последовательно, а общее время представляло собой сумму времени выполнения всех потоков. Как я могу создать потоки одновременно, чтобы потоки снова могли работать параллельно? Нужно ли создавать и запускать их вручную?
Я пробовал только циклы, я не могу придумать другого решения для этой проблемы, и я также не смог найти никакого решения в Интернете.
Ответы 1
Вы понимаете, что делает t.join()? Он вообще ничего не делает с потоком t. Единственное, что делает t.join(), это ждёт завершения потока t, а затем возвращается.
Причина, по которой ваши потоки выполняются последовательно, заключается в том, что ваш код ожидает завершения каждого потока, прежде чем запустить следующий:
for i in range(100):
threads[i].start()
threads[i].join()
Вместо этого вы хотите сначала запустить все потоки, а затем join все потоки.
for i in range(100):
threads[i].start()
for i in range(100):
threads[i].join()
@TimRoberts, согласен. Ваша версия более стильная, особенно потому, что в ней отсутствует магическое число , 100; но бывают дни, когда мне кажется, что лучший способ проиллюстрировать проблему — показать малейшее изменение, которое ее решает. Вчера был один из таких дней.
Я это ясно понимаю: я делаю то же самое. Мой комментарий не является критикой вашего ответа, а скорее альтернативой.
Или, еще лучше,
for t in threads:/t.start()/for t in threads:/t.join().