U ºO.e²ã@s²UdZddlZddlZddlZddlZddlmZmZe e ¡Z e d¡jZ eed<e d¡jZeed<Gdd „d ejjƒZed ejfed<e ¡dkrªddlZejZneZdS) z3Helpers for cross-plaform multiprocessing support. éN)ÚCallableÚTypeÚforkÚForkProcessÚspawnÚSpawnProcesscsHeZdZdZ‡fdd„Z‡fdd„Z‡fdd„Zdd „Zd d„Z‡Z S)ÚMacSafeQueuea Multiprocessing queues do not have qsize attributes on MacOS. This is slower but more portable version of the multiprocessing Queue that adds a explicit counter Reference : https://github.com/keras-team/autokeras/commit/4ddd568b06b4045ace777bc0fb7bc18573b85a75 cs4d|krt ¡|d<tƒj||Žt dd¡|_dS)NÚctxÚir)ÚmultiprocessingÚget_contextÚsuperÚ__init__ÚValueÚ_counter)ÚselfÚargsÚkwargs©Ú __class__©ús/mounts/lovelace/software/anaconda3/envs/qiime2-shotgun-2023.9/lib/python3.8/site-packages/parsl/multiprocessing.pyrszMacSafeQueue.__init__c s8tƒj||Ž}|j ¡|jjd7_W5QRX|S©Né)r ÚputrÚget_lockÚvalue©rrrÚxrrrr!szMacSafeQueue.putc s8tƒj||Ž}|j ¡|jjd8_W5QRX|Sr)r Úgetrrrrrrrr(szMacSafeQueue.getcCs|jjS©N©rr©rrrrÚqsize/szMacSafeQueue.qsizecCs |jjSr r!r"rrrÚempty2szMacSafeQueue.empty) Ú__name__Ú __module__Ú__qualname__Ú__doc__rrrr#r$Ú __classcell__rrrrrsr.Ú SizedQueueÚDarwin)r(ÚloggingrZmultiprocessing.queuesÚplatformÚtypingrrÚ getLoggerr%ÚloggerrÚProcessrÚ__annotations__rÚqueuesÚQueuerÚsystemr*rrrrÚs &