U ڲg| @sZUdZddlmZddlZddlZddlZddlmZmZm Z m Z ddl m Z m Z ejZded<d Zded <e d Ze rejZded <ejZded <n A Queue subclass with an interruptible get() method. TNbool float | Noner )blocktimeoutreturncs|dkr d}tj||dS)Ng@)rr)superget)rrr __class__rrr!0sz Queue.get)TN)rrr__doc__r! __classcell__rrr"rr+src@s eZdZdS)AQueueNrrrrrr&7sr&rz(Callable[..., Coroutine[Any, Any, None]]ztuple[Any, ...]z str | None)fargsnamercCstj|||dS)z, Equivalent to asyncio.create_task. )r))asyncioZ create_task)r'r(r)rrraspawn;sr+zCallable[..., Any]zthreading.ThreadcCstj|||dd}||S)z= Equivalent to creating and running a daemon thread. T)targetr(r)daemon) threadingThreadstart)r'r(r)trrrspawnFsr2rzasyncio.Task[Any]rNone)tasksrrcs\tj|}z2|dk r0tjt||dIdHn |IdHWntjk rRYnXdSdS)7 Equivalent to asyncio.gather or Thread.join() Nr3)r*gatherwait_forZshield TimeoutError)rr5waitrrragatherSs r;cGs"|D]}|sq||qdS)r6N)is_alivejoin)rr5r1rrrr7csr7)rN)rN)r$ __future__rqueuer*r.typingrrrr_compatrr r/r __annotations__r r rr rtyperr&r+r2r;r7rrrrs2