promise fuckups

gistfile1.txt

from promise import Promise
from threading import Thread
import threading
import time
import functools

def on_resolve(issued_by, fn):
    name = threading.current_thread().getName()
    if issued_by != name:
        print(issued_by, name)
    
def worker():
    my_name = threading.current_thread().getName()
    now = time.time()
    while now + 5 > time.time():
        promise = Promise.resolve(None)
        promise.then(functools.partial(on_resolve, my_name))
        #time.sleep(0.001)

threads = []
for i in range(3):
    threads.append(Thread(target=worker))

for thread in threads:
    thread.start()
    
for thread in threads:
    thread.join()