import random
import threading
from time import time

from faker import Faker

from a import client

fake = Faker()
t0 = time()
dt = 0


class MyTh(threading.Thread):
    def setup(self, rng, cl):
        self.rng = rng
        self.cl = cl

    def run(self):
        for x in self.rng:
            key = ('test', 'demo', f'foo{x}')
            record = {'name': fake.name(), 'age': random.randint(0, 100)}

            client.put(key, record, meta=dict(ttl=2000))

            if x % 1000 == 0:
                print(x, time() - t0)


threads = []
t0=time()
for x in range(100):
    tsk = range(x * 10000, (x + 1) * 10000)
    threads.append(MyTh())
    threads[-1].setup(tsk, client)

for t in threads:
    t.start()

for t in threads:
    t.join()


print(time()-t0)
client.close()