def test():
    while locked:
        time.sleep(10)
threads = []
t = threading.Thread(target=worker)
threads.append(t)
t = threading.Thread(target=test)
threads.append(t)
for th in threads:
    th.start()
for th in threads:
    th.join()
Заставить поток блокировать выполнение всех других потоков