o DDi@sUdZddlmZddlZddlZddlZddlmZmZddl m Z m Z ddl m Z ejZded <ejdZded <ejZejZe d ZGd d d ejeZGdddejeZ  d)d*ddZ  d)d+ddZddd,d%d&Zddd-d'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)TypeVarrWorkerAWorkerTcs$eZdZdZd d fd d ZZS)Queuez> A Queue subclass with an interruptible get() method. TNblockbooltimeout float | Nonereturnr cs|durd}tj||dS)Ng@)r r)superget)selfr r __class__I/var/www/Datamplify/venv/lib/python3.10/site-packages/psycopg/_acompat.pyr"sz Queue.get)TN)r rrrrr )__name__ __module__ __qualname____doc__r __classcell__rrrrr sr c@s eZdZdS)AQueueN)rrrrrrrr)srrf(Callable[..., Coroutine[Any, Any, None]]argstuple[Any, ...]name str | Nonerasyncio.Task[None]cCstj|||dS)z, Equivalent to asyncio.create_task. )r#)asyncio create_task)rr!r#rrraspawn-sr(Callable[..., Any]threading.ThreadcCstj|||dd}||S)z= Equivalent to creating and running a daemon thread. T)targetr!r#daemon) threadingThreadstart)rr!r#trrrspawn8sr1rtasksasyncio.Task[Any]rrNonecs\tj|}z|durtjt||dIdHWdS|IdHWdStjy-YdSw)7 Equivalent to asyncio.gather or Thread.join() Nr2)r&gatherwait_forshield TimeoutError)rr3waitrrragatherEs  r<cGs"|D] }|s q||qdS)r6N)is_alivejoin)rr3r0rrrr7Us  r7)rN)rr r!r"r#r$rr%)rr)r!r"r#r$rr*)r3r4rrrr5)r3r*rrrr5)r __future__rqueuer&r-typingrrcollections.abcrr_compatrr.r __annotations__Taskr LockALockr r rr(r1r<r7rrrrs.