YfXddlZddlZddlmZmZmZmZedZGddeeZy)N)AnyGenericOptionalTypeVarTc\eZdZdeddfdZdeeddfdZdeefdZd dZ d d Z d d Z y) ScaleneSigQueueprocessreturnNctj|_||_d|_t j |_y)N)queue SimpleQueuer thread threadingRLocklock)selfr s X/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/scalene/scalene_sigqueue.py__init__zScaleneSigQueue.__init__ s.5:5F5F5H  26 OO% itemc:|jj|y)zAdd an item to the queue.N)r putrrs rrzScaleneSigQueue.puts trc6|jjS)zGet one item from the queue.)r getrs rrzScaleneSigQueue.getszz~~rc|jsAtj|jd|_|jj yy)zStart processing.T)targetdaemonN)rrThreadrunstartrs rr#zScaleneSigQueue.starts8{{#**$((4HDK KK   rc|jr=|jjd|jjd|_yy)zStop processing.N)rr rjoinrs rstopzScaleneSigQueue.stops7 ;; JJNN4  KK   DK rc |jj}|y|j5|j|dddB#1swY xYw)z_Run the function processing items until stop is called. Executed in a separate thread.N)r rrr rs rr"zScaleneSigQueue.run'sN::>>#D| $ d# $  $ $s AA )r N) __name__ __module__ __qualname__rrrrrrr#r&r"rrr r sK&&&   Xa[   $rr ) r rtypingrrrrrr r+rrr-s* 22 CL($gaj($r