YtjfUdZddlmZddlZddlZddlZddlmZmZddl m Z m Z ddl m Z ejZded <ejdZded <ejZejZe d ZGd d ejeZGddejeZ d%d&dZ d%d'dZddd(d#Zddd)d$ZdS)*z Utilities to ease the differences between async and sync code. These object offer a similar interface between sync and async versions; the script async_to_sync.py will replace the async names with the sync names when generating the sync version. ) annotationsN)Any TypeAlias)Callable Coroutine)TypeVarrWorkerAWorkerTc&eZdZdZd d fd ZxZS) Queuez> A Queue subclass with an interruptible get() method. TNblockbooltimeout float | Nonereturnr cR|d}t||S)Ng@)rr)superget)selfrr __class__s N/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/psycopg/_acompat.pyrz Queue.get"s' ?(Gww{{{888)TN)rrrrrr )__name__ __module__ __qualname____doc__r __classcell__)rs@rrrsL99999999999rrceZdZdS)AQueueN)rrrrrr!r!)sDrr!r"f(Callable[..., Coroutine[Any, Any, None]]argstuple[Any, ...]name str | Nonerasyncio.Task[None]c4tj|||S)z, Equivalent to asyncio.create_task. )r')asyncio create_task)r#r%r's raspawnr--s   qq$xd 3 3 33rCallable[..., Any]threading.Threadc^tj|||d}||S)z= Equivalent to creating and running a daemon thread. T)targetr%r'daemon) threadingThreadstart)r#r%r'ts rspawnr78s/ 4EEEAGGIII Hrrtasksasyncio.Task[Any]rrNonecKtj|} |/tjtj||d{Vn|d{VdS#tj$rYdSwxYw)7 Equivalent to asyncio.gather or Thread.join() Nr8)r+gatherwait_forshield TimeoutError)rr9waits ragatherrCEs >5 !D  "7>$#7#7III I I I I I I I IJJJJJJJ        s9A A A cd|D],}|s||-dS)r=N)is_alivejoin)rr9r6s rr>r>UsAzz||   wr)r"N)r#r$r%r&r'r(rr))r#r.r%r&r'r(rr/)r9r:rrrr;)r9r/rrrr;)r __future__rqueuer+r3typingrrcollections.abcrr_compatr r4r __annotations__Taskr LockALockr rr!r-r7rCr>r"rrrPs#""""" !!!!!!!!////////$$$$$\$'''''~  GCLL 9 9 9 9 9EKN 9 9 9     W]1    44444      FJ       >Br