import time
import random

import univention.admin
from threading import Thread

lo, pos = univention.admin.uldap.getAdminConnection()


def job(lo, pos, module):
    # for _ in range(1000):
    #     time.sleep(random.uniform(0, 0.1))
    while True:
        univention.admin.modules.init(lo, pos, module, force_reload=True)

for module_name in ('users/user',):
    print(module_name)

    univention.admin.modules.update()
    module = univention.admin.modules.get(module_name)
    threads = []
    for x in range(100):
        t = Thread(target=job, args=(lo, pos, module))
        threads.append(t)
        t.start()

    for t in threads:
        t.join()