Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import time
- from multiprocessing import freeze_support
- import multiprocessing
- #cantidad de horas a esperar por cada ciclo
- HORA_ESPERA = 1
- def worker(q):
- while True:
- try:
- time.sleep(HORA_ESPERA*3600)
- except Exception as e:
- # si falla esperar 60 segundos
- time.sleep(60)
- return
- queue = multiprocessing.Queue()
- p = multiprocessing.Process(target=worker, args=(queue,))
- p.daemon = True
- p.start()
- queue.put('mensaje al worker')
- queue.close()
Add Comment
Please, Sign In to add comment