Olá, estou estudando o funcionamento das threads e fiz um programa onde existe uma função que printa o horário atual de 'n' em 'n' segundos, e gostaria de criar um processamento paralelo onde eu posso jogar essa função em um processo para printar o horário atual de 3 em 3 segundos e o outro processo de 5 em 5 segundos por exemplo, este é o código que eu fiz:
import time
import datetime
import threading
def temporizador(worker, amplitude):
# Não é necessário entender o funcionamento dessa função
while True:
unix_agora = (datetime.datetime.utcnow() - datetime.datetime(1970, 1, 1)).total_seconds()
unix_agora_int = int(unix_agora)
unix_agora_dec = unix_agora - unix_agora_int
resto = int(unix_agora) % amplitude
tempo_fim = int(unix_agora - resto - unix_agora_dec)
print('worker', worker, '|', datetime.datetime.now())
espera = tempo_fim + amplitude - (datetime.datetime.utcnow() - datetime.datetime(1970, 1, 1)).total_seconds()
time.sleep(espera)
i = 0
threading.Thread(target=temporizador, args=('1', 3)).start()
threading.Thread(target=temporizador, args=('2', 5)).start()
o programa funciona, porém frequentemente a mensagem printada de uma thread se superpõe à outra ficando tudo misturado. Isto é o que acontece quando eu rodo o programa:
worker 1 | 2019-06-04 21:08:50.108693
worker 2 | 2019-06-04 21:08:50.108693
worker 1 | 2019-06-04 21:08:51.002126
worker 1 | 2019-06-04 21:08:54.000400
worker 2 | 2019-06-04 21:08:55.001707
worker 1 | 2019-06-04 21:08:57.000754
worker 1 | 2019-06-04 21:09:00.001023
worker 2 | 2019-06-04 21:09:00.001023
worker 1 | 2019-06-04 21:09:03.000719
worker 2 | 2019-06-04 21:09:05.000572
worker 1 | 2019-06-04 21:09:06.001783
worker 1 | 2019-06-04 21:09:09.001796
worker 2 | 2019-06-04 21:09:10.001719
worker 1 | 2019-06-04 21:09:12.001740
worker worker 21 | |2019-06-04 21:09:15.001721 2019-06-04 21:09:15.001721
worker 1 | 2019-06-04 21:09:18.001723
worker 2 | 2019-06-04 21:09:20.001753
worker 1 | 2019-06-04 21:09:21.001057
.
Como eu posso corrigir este bug? Agradeço.