Threads

threads.py

import threading
from zcached import ZCached, Result


def worker(worker_id: int, zcached: ZCached) -> None:
    result: Result[str] = zcached.ping()
    print(f"Worker {worker_id} | {result.value}")


client = ZCached(host="localhost", port=1234, pool_size=2)
client.run()

if not client.is_alive():
    raise RuntimeError("Something went wrong :(")

threads = [threading.Thread(target=worker, args=(x, client)) for x in range(10)]
for thread in threads:
    thread.start()


# There is also a second, easier way. However, this one has limitations.
"""
for w_id in range(10):
    client.connection_pool.run_in_thread(func=worker, worker_id=w_id, zcached=client)
"""