Добрый день. есть скрипт, он запускает в 5 потоков одну и ту же функцию, при помощи threading. Функция при определенных условиях ставится на паузу time.sleep. НО! остальные 4 потока продолжают работать. как сделать так, чтобы на паузу вставали все 5 потоков?
4
-
Можно сделать общую переменную и в каждом потоке её проверять. Можно отправлять какой-то параметр потокам через очередь.– Sergey Gornostaev10 сен 2017 в 15:10
-
@sergey-gornostaev тоже уже подумал про общую переменную, так наверно будет проще, спасибо!– Игорь Жданов10 сен 2017 в 15:14
-
семафор это называется.) смотри модули threading.Lock– eri10 сен 2017 в 23:31
-
1А мне кажется для этой темы ближе docs.python.org/3/library/threading.html#condition-objects хоть с моей колокольни он устроен несколько странновато.– vitidev11 сен 2017 в 5:18
Добавить комментарий
|
3 ответа
Чтобы останавливать итерации в функции при каждом срабатывании условия в любом из потоков на 5 секунд (для каждого срабатывания):
#!/usr/bin/env python3
"""Stop all threads for 5 seconds if some condition happens."""
import random
import threading
import time
def safe_write(s, lock=threading.Lock()):
with lock:
print(s, end="", flush=True)
def worker(char, started: threading.Event, lock=threading.Lock()):
while started.wait():
safe_write(char) # do some work
if random.random() < .025: # if some condition
# pause for 5 seconds
with lock: # the pauses are consecutive if the condition
# triggers in more than one thread
started.clear() # this stops cycles in all threads
try:
safe_write(" wait")
for c in ".....":
safe_write(c)
time.sleep(1)
safe_write("continue\n")
finally:
started.set() # start the cycles again
else:
time.sleep(.1)
started = threading.Event()
for char in "12345":
threading.Thread(target=worker, args=[char, started], daemon=True).start()
print("Press Enter to exit", flush=True)
started.set() # start all cycles
input()
Это можно реализовать, используя более примитивный объект, такой как threading.Condition()
:
#!/usr/bin/env python3 -u
"""Stop all threads for 5 seconds if some condition happens."""
import random
import threading
import time
def worker(char, cv=threading.Condition()):
can_run = True
while True:
safe_write(char) # do some work
if random.random() < .025: # if some condition
# pause for 5 seconds
with cv: # the pauses are consecutive if the condition triggers in more than one thread
can_run = False # this stop cycles in all threads
try:
safe_write(" wait V seconds")
for c in ".....":
safe_write(c)
time.sleep(1)
safe_write("continue\n")
finally:
can_run = True # start the cycles again
cv.notify_all()
else:
time.sleep(.1)
with cv: # wait until we can run
while not can_run:
cv.wait()
print("Press Enter to exit", flush=True)
for char in "12345":
threading.Thread(target=worker, args=[char], daemon=True).start()
input()
lock=threading.Lock()
in threads:
lock.acquire()
time.sleep(5)
lock.release()
-
А можете показать пример использования? Чтобы можно было запустить и увидеть– gil9red31 июл 2018 в 5:37
-
кст, ваш пример можно упростить через with-выражение: docs.python.org/3/library/…– gil9red31 июл 2018 в 11:54
import threading
from datetime import datetime
import time
def job(p):
global lock
lock.acquire()
for i in range(0,5):
print p, datetime.now().strftime('%H:%M:%S'), threading.currentThread().getName()
time.sleep(1)
lock.release()
lock=threading.Lock()
for i in range(0,3):
t=threading.Thread(target=job, args=(i,))
t.start()
t.join()
-
-
-
Правильно, потому что у каждого потока в примере есть пауза. Конечно эта пауза должна вызываться условно. Я просто показал как использовать object Lock 2 авг 2018 в 7:40
-
Одного lock для задачи мало. Посмотрите на код в моём ответе. Если думаете, что достаточно, то продемонстрируйте как все потоки останавливать [на время] одновременно при срабатывании условия в каком-то одном потоке.– jfs2 авг 2018 в 20:10