o Ph@s8ddlmZddlmZddlmZGdddeZdS))Queue)Thread)ListcsPeZdZd deddffdd Zdeefdd Zgfdeefd d ZZ S) rrmaxsizereturnNcstj|ddS)N)r)super__init__)selfr __class__R/var/www/html/env_mimamsha/lib/python3.10/site-packages/translatepy/utils/queue.pyrszQueue.__init__threadscCs|D] }|r dSqdS)NTF)is_alive)r rthreadr r r _threads_are_alive s zQueue._threads_are_alivecCs~|j2|s||r|j|s||s |s#td|}|j|WdS1s8wYdS)zrRemove and return an item from the queue. It waits for a value or the termination of all threads zNo thread returned a valueN) not_empty_qsizerwait ValueError_getnot_fullnotify)r ritemr r r gets  $z Queue.get)r) __name__ __module__ __qualname__intrrrrr __classcell__r r r r rsrN)queuer_Queue threadingrtranslatepy.utils.annotationsrr r r r s