����JFIF���������
1#@!#!123s
D7net
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
alt
/
python312
/
lib64
/
python3.12
/
multiprocessing
/
__pycache__
/
Filename :
queues.cpython-312.opt-1.pyc
back
Copy
� ����5[Yh�1���������������������������g�d��Z�ddlZddlZddlZddlZddlZddlZddlZddlZddl m Z mZ�ddlZddl mZ�ddl mZ�ej ������������������j"������������������ZddlmZmZmZmZmZ��G�d��d e�������Z�e��������Z�G�d ��de�������Z�G�d��d e�������Zy))�Queue�SimpleQueue� JoinableQueue�����N)�Empty�Full����)� connection)�context)�debug�info�Finalize�register_after_fork� is_exitingc��������������������������e�Zd�Zdd�Zd��Zd��Zd��Zdd�Zdd�Zdd�Z d ��Z d ��Zd��Zd��Z d ��Zd��Zd��Zd��Zd��Zd��Zed����������Zed����������Zed����������Zed����������Z�eej6�������������������������Zy)r���c����������������������|dk��rddl�m}�||�_��������t��������j������������������d��������\��|�_��������|�_��������|j��������������������������|�_��������t��������j��������������������������|�_��������t��������j������������������dk(��rd�|�_��������n|j��������������������������|�_��������|j������������������|�������|�_��������d|�_��������|�j%���������������������������t��������j������������������dk7��rt'��������|�t(��������j*��������������������������y�y�)Nr���r���)� SEM_VALUE_MAXF��duplex�win32)�synchronizer����_maxsizer ����Pipe�_reader�_writer�Lock�_rlock�os�getpid�_opid�sys�platform�_wlock�BoundedSemaphore�_sem� _ignore_epipe�_resetr���r����_after_fork��self�maxsize�ctxs��� �=/opt/alt/python312/lib64/python3.12/multiprocessing/queues.py�__init__zQueue.__init__%���s��������a�<�=��� �%/�_�_�E�%B�"���d�l��h�h�j����Y�Y�[�� ��<�<�7�"��D�K��(�(�*�D�K��(�(��1�� �"������ ��<�<�7�"���e�&7�&7�8��#�����c������������������������t��������j������������������|���������|�j������������������|�j������������������|�j������������������|�j ������������������|�j������������������|�j������������������|�j������������������|�j������������������fS��N) r ����assert_spawningr%���r���r���r���r���r"���r$���r����r)���s��� r,����__getstate__zQueue.__getstate__9���sP����������%��"�"�D�M�M�4�<�<�������T�[�[�$�)�)�T�Z�Z�A�� Ar.���c����������� ������������|\��|�_���������|�_��������|�_��������|�_��������|�_��������|�_��������|�_��������|�_��������|�j���������������������������y�r0���) r%���r���r���r���r���r"���r$���r���r&����r)����states��� r,����__setstate__zQueue.__setstate__>���s5������<A� :�� �T�]�D�L�$�,� ��d�k�4�9�d�j���� r.���c������������������>�����t��������d��������|�j������������������d���������y�)NzQueue._after_fork()T)� after_fork)r���r&���r2���s��� r,���r'���zQueue._after_forkC���s������ �#�$����t��$r.���c����������������������|r|�j�������������������j���������������������������n,t��������j������������������t��������j���������������������������������|�_���������t��������j��������������������������|�_��������d�|�_��������d�|�_ ��������d|�_ ��������d|�_��������d�|�_��������|�j������������������j������������������|�_��������|�j ������������������j"������������������|�_��������|�j ������������������j&������������������|�_��������y��NF)� _notempty�_at_fork_reinit� threading� Conditionr����collections�deque�_buffer�_thread�_jointhread�_joincancelled�_closed�_closer���� send_bytes�_send_bytesr���� recv_bytes�_recv_bytes�poll�_poll)r)���r9���s��� r,���r&���zQueue._resetG���s���������N�N�*�*�,�&�0�0����1A�B�D�N�"�(�(�*���������#����������<�<�2�2����<�<�2�2����\�\�&�&�� r.���Nc������������������b����|�j�������������������rt��������d|��d���������|�j������������������j������������������||�������st���������|�j ������������������5��|�j�������������������|�j���������������������������|�j������������������j������������������|��������|�j ������������������j���������������������������d�d�d���������y�#�1�sw�Y���y�xY�w�NzQueue z is closed)rF���� ValueErrorr$����acquirer���r<���rC���� _start_threadrB����append�notify�r)����obj�block�timeouts��� r,����putz Queue.putV���s�������<�<��v�d�X�Z�8�9�9��y�y� � ���0��J� �^�^��|�|�#��"�"�$��L�L����$��N�N�!�!�#� ��^�^�s ���� AB%�%B.c�����������������������|�j�������������������rt��������d|��d���������|rB|�@|�j������������������5��|�j��������������������������}d�d�d���������|�j������������������j���������������������������n�|rt ��������j��������������������������|z���}|�j������������������j������������������||�������st��������� �|r.t ��������j��������������������������z ��}|�j������������������|�������st���������|�j��������������������������st���������|�j��������������������������}|�j������������������j���������������������������|�j������������������j���������������������������t��������j�������������������������S�#�1�sw�Y�����xY�w#�|�j������������������j���������������������������w�xY�wrO���) rF���rP���r���rK���r$����release�time� monotonicrQ���r���rM����_ForkingPickler�loads)r)���rW���rX����res�deadlines��� r,����getz Queue.getb���s ������<�<��v�d�X�Z�8�9�9��W�_�����&�&�(�����I�I������>�>�+�g�5���;�;�&�&�u�g�6��� &��&����)9�9�G��:�:�g�.�#�������K��&�&�(��� � �!�!�#����#�#�%��$�$�S�)�)�)����$����#�#�%�s����D;�A0E��;E�E#c������������������d�����|�j�������������������|�j������������������j������������������j��������������������������z ��S�r0���)r���r$����_semlock� _get_valuer2���s��� r,����qsizezQueue.qsize|���s$�������}�}�t�y�y�1�1�<�<�>�>�>r.���c������������������$�����|�j���������������������������S�r0����rM���r2���s��� r,����emptyzQueue.empty������������:�:�<��r.���c������������������J�����|�j�������������������j������������������j��������������������������S�r0���)r$���rd����_is_zeror2���s��� r,����fullz Queue.full����s�������y�y�!�!�*�*�,�,r.���c������������������$�����|�j������������������d�������S�r;���)rb���r2���s��� r,���� get_nowaitzQueue.get_nowait����s�������x�x���r.���c������������������&�����|�j������������������|d�������S�r;���)rY����r)���rV���s��� r,���� put_nowaitzQueue.put_nowait����s�������x�x��U�#�#r.���c������������������L�����d|�_���������|�j������������������}|rd�|�_���������|���������y�y�)NT)rF���rG���)r)����closes��� r,���rt���zQueue.close����s&���������������D�K��G��r.���c������������������T�����t��������d��������|�j������������������r|�j���������������������������y�y�)NzQueue.join_thread())r���rD���r2���s��� r,����join_threadzQueue.join_thread����s%������ �#�$���������r.���c������������������|�����t��������d��������d|�_�������� �|�j������������������j���������������������������y�#�t��������$�r�Y�y�w�xY�w)NzQueue.cancel_join_thread()T)r���rE���rD����cancel�AttributeErrorr2���s��� r,����cancel_join_threadzQueue.cancel_join_thread����s<������ �*�+�"��� ����#�#�%���� �� �s����/�� ;�;c������������������������|�j�������������������j���������������������������t��������j������������������dk(��r|�j������������������j���������������������������|�j���������������������������|�j���������������������������y�)Nr���)r���rt���r ���r!���r���rv���r2���s��� r,����_terminate_brokenzQueue._terminate_broken����sG������� ��������<�<�7�"��L�L��� �� � �����r.���c������������������,����t��������d��������|�j������������������j���������������������������t��������j������������������t ��������j������������������|�j������������������|�j������������������|�j������������������|�j������������������|�j������������������j������������������|�j������������������j������������������|�j������������������|�j������������������|�j������������������f dd��������|�_�������� �t��������d��������|�j ������������������j#���������������������������t��������d��������|�j$������������������sJt'��������|�j ������������������t ��������j(������������������t+��������j,������������������|�j �������������������������gd��������|�_��������t'��������|�t ��������j0������������������|�j������������������|�j������������������gd ��������|�_��������y�#��d�|�_����������xY�w) NzQueue._start_thread()�QueueFeederThreadT)�target�args�name�daemonzdoing self._thread.start()z... done self._thread.start()���)�exitpriority� ���)r���rB����clearr>����Threadr����_feedr<���rI���r"���r���rt���r���r%����_on_queue_feeder_errorr$���rC����startrE���r ����_finalize_join�weakref�refrD����_finalize_closerG���r2���s��� r,���rR���zQueue._start_thread����s2����� �%�&�� ������ �'�'��;�;��,�,�����0@�0@��+�+�t�|�|�1�1�4�<�<�3E�3E��$�$�d�&A�&A��)�)���%�� ��� ��.�/��L�L��� ��1�2���"�"�'����e�2�2����T�\�\�*�+�� �D�����%�'�'� �\�\�4�>�>�*������ �� �D�L��s���� 0F �� Fc������������������z�����t��������d���������|���������}|�|j���������������������������t��������d��������y�t��������d��������y�)Nzjoining queue threadz... queue thread joinedz... queue thread already dead)r����join)�twr�threads��� r,���r����zQueue._finalize_join����s3������ �$�%�������K�K�M��+�,��1�2r.���c�����������������������t��������d��������|5��|�j������������������t����������������|j���������������������������d�d�d���������y�#�1�sw�Y���y�xY�w)Nztelling queue thread to quit)r���rS���� _sentinelrT���)�buffer�notemptys��� r,���r����zQueue._finalize_close����s.������ �,�-� ��M�M�)�$��O�O����X�X�s ����&=�Ac ����������������������t��������d��������|j������������������} |j������������������} |j������������������}|�j������������������}t ��������} t��������j������������������dk7��r|j������������������}|j������������������}nd�} � ��| ��������� �|�s�|����������| ��������� � ��|��������}|| u�rt��������d���������|����������|���������y�t��������j������������������|�������}|� �||��������n�|��������� ��||�������������������]#��| ���������w�xY�w#�����������w�xY�w#�t��������$�r�Y�nw�xY�wno#�t��������$�rc}|r#t��������|dd�������t��������j������������������k(��rY�d�}~y�t����������������rt!��������d|��������Y�d�}~y�|j����������������������������||��������Y�d�}~nd�}~ww�xY�w��)Nz$starting thread to feed data to piper���z%feeder thread got sentinel -- exiting�errnor���zerror in queue thread: %s)r���rQ���r[����wait�popleftr����r ���r!���r^����dumps� IndexError� Exception�getattrr�����EPIPEr���r���)r����r����rH���� writelock�reader_close�writer_close�ignore_epipe�onerror� queue_sem�nacquire�nrelease�nwait�bpopleft�sentinel�wacquire�wreleaserV����es��� r,���r����zQueue._feed����sh������ �4�5��#�#���#�#��� � ���>�>�����<�<�7�"� �(�(�H� �(�(�H��H��- $�� ��!����J���&�j���(�?�!�"I�J�(�N�(�N�"��.�3�3�C�8��#�+�&�s�O�$�J�+� *�3�� (� �#�����J��&�!)� ��!���������� $��G�A�w��$:�e�k�k�$I�� ��<��4�a�8����%�%�'��A�s�O�O��# $��;�sx����2D��: C)��D��%D��1'D��C5��!D��) C2�2D��5 C>�>D�� D � D��D � D�� E=� E8�?E8�E8�8E=c������������������,�����ddl�}|j���������������������������y)z� Private API hook called when feeding data in the background thread raises an exception. For overriding by concurrent.futures. r���N)� traceback� print_exc)r����rV���r����s��� r,���r����zQueue._on_queue_feeder_error&��s������� ����r.����r���)F�TN)�__name__� __module__�__qualname__r-���r3���r7���r'���r&���rY���rb���rf���ri���rm���ro���rr���rt���rv���rz���r|���rR����staticmethodr����r����r����r�����classmethod�types�GenericAlias�__class_getitem__��r.���r,���r���r���#���s�������9�(A� � %� '� $�*�4?� �-��$�����%�N��3���3���������<$���<$�|�������$�E�$6�$6�7�r.���r���c��������������������4�����e�Zd�Zdd�Zd��Zd��Zd d�Zd��Zd��Zy) r���c����������������������t���������j������������������|�||���������|j������������������d�������|�_��������|j ��������������������������|�_��������y�)N)r+���r���)r���r-���� Semaphore�_unfinished_tasksr?����_condr(���s��� r,���r-���zJoinableQueue.__init__>��s2������ ���t�W�#��.�!$���q�!1����]�]�_�� r.���c������������������^�����t���������j������������������|��������|�j������������������|�j������������������fz���S�r0���)r���r3���r����r����r2���s��� r,���r3���zJoinableQueue.__getstate__C��s'�������!�!�$�'�4�:�:�t�7M�7M�*N�N�Nr.���c������������������Z�����t���������j������������������|�|d�d���������|dd��\��|�_��������|�_��������y�)N���)r���r7���r����r����r5���s��� r,���r7���zJoinableQueue.__setstate__F��s-������ ���4��s���,�-2�2�3�Z�*�� �D�*r.���Nc�����������������������|�j�������������������rt��������d|��d���������|�j������������������j������������������||�������st���������|�j ������������������5��|�j������������������5��|�j�������������������|�j���������������������������|�j������������������j������������������|��������|�j������������������j���������������������������|�j ������������������j���������������������������d�d�d���������d�d�d���������y�#�1�sw�Y����xY�w#�1�sw�Y���y�xY�wrO���)rF���rP���r$���rQ���r���r<���r����rC���rR���rB���rS���r����r[���rT���rU���s��� r,���rY���zJoinableQueue.putJ��s��������<�<��v�d�X�Z�8�9�9��y�y� � ���0��J� �^�^�T�Z�Z��|�|�#��"�"�$��L�L����$��"�"�*�*�,��N�N�!�!�#��(�^�^�Z�Z��^�^�s%���� C �A,C�C �C �C � C)c����������������������|�j�������������������5��|�j������������������j������������������d�������st��������d��������|�j������������������j������������������j��������������������������r|�j�������������������j ���������������������������d�d�d���������y�#�1�sw�Y���y�xY�w)NFz!task_done() called too many times)r����r����rQ���rP���rd���rl���� notify_allr2���s��� r,���� task_donezJoinableQueue.task_doneW��s[������ �Z�Z��)�)�1�1�%�8� �!D�E�E��%�%�.�.�7�7�9�� � �%�%�'� ��Z�Z�s����A%A;�;Bc������������������������|�j�������������������5��|�j������������������j������������������j��������������������������s|�j�������������������j ���������������������������d�d�d���������y�#�1�sw�Y���y�xY�wr0���)r����r����rd���rl���r����r2���s��� r,���r����zJoinableQueue.join^��s9������ �Z�Z��)�)�2�2�;�;�=�� � ���!���Z�Z�s����?A�Ar����r����) r����r����r����r-���r3���r7���rY���r����r����r����r.���r,���r���r���<��s!������%� O�8�$�(�"r.���r���c��������������������Z�����e�Zd�Zd��Zd��Zd��Zd��Zd��Zd��Zd��Z �e ej�������������������������Z y) r���c����������������� ����t��������j������������������d��������\��|�_��������|�_��������|j ��������������������������|�_��������|�j������������������j������������������|�_��������t��������j������������������dk(��rd�|�_ ��������y�|j ��������������������������|�_ ��������y�)NFr���r���)r ���r���r���r���r���r���rL���rM���r ���r!���r"���)r)���r+���s��� r,���r-���zSimpleQueue.__init__i��sW������%/�_�_�E�%B�"���d�l��h�h�j����\�\�&�&�� ��<�<�7�"��D�K��(�(�*�D�Kr.���c������������������l�����|�j�������������������j���������������������������|�j������������������j���������������������������y�r0���)r���rt���r���r2���s��� r,���rt���zSimpleQueue.closer��s"�����������������r.���c������������������$�����|�j���������������������������S�r0���rh���r2���s��� r,���ri���zSimpleQueue.emptyv��rj���r.���c�����������������������t��������j������������������|���������|�j������������������|�j������������������|�j������������������|�j ������������������fS�r0���)r ���r1���r���r���r���r"���r2���s��� r,���r3���zSimpleQueue.__getstate__y��s/����������%����d�l�l�D�K�K����E�Er.���c������������������p�����|\��|�_���������|�_��������|�_��������|�_��������|�j�������������������j������������������|�_��������y�r0���)r���r���r���r"���rL���rM���r5���s��� r,���r7���zSimpleQueue.__setstate__}��s)������AF�>���t�|�T�[�$�+��\�\�&�&�� r.���c�����������������������|�j�������������������5��|�j������������������j��������������������������}d�d�d���������t��������j �������������������������S�#�1�sw�Y����xY�wr0���)r���r���rJ���r^���r_���)r)���r`���s��� r,���rb���zSimpleQueue.get���s;������ �[�[��,�,�)�)�+�C�����$�$�S�)�)���[�s����A�Ac�����������������������t���������j������������������|�������}|�j�������������������|�j������������������j ������������������|��������y�|�j������������������5��|�j������������������j ������������������|��������d�d�d���������y�#�1�sw�Y���y�xY�wr0���)r^���r����r"���r���rH���rq���s��� r,���rY���zSimpleQueue.put���sQ�������#�#�C�(���;�;���L�L�#�#�C�(�������'�'��,�����s���� A/�/A8N)r����r����r����r-���rt���ri���r3���r7���rb���rY���r����r����r����r����r����r.���r,���r���r���g��s9������%�� �F�'�*�-��$�E�$6�$6�7�r.���r���)�__all__r ���r���r>���r@���r\���r����r����r�����queuer���r����_multiprocessing��r ���r ���� reduction�ForkingPicklerr^����utilr���r���r ���r���r����objectr���r����r���r���r����r.���r,����<module>r�������sx������4��� �� ����������������������#�#�2�2���H��H�L8�F��L8�^� �H� �%"�E��%"�V*8�&��*8r.���