f. g d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl m
Z
m Z ddl Z ddl
mZ ddl
mZ ej j ZddlmZmZmZmZmZ G d d e Z e Z G d
d e Z G d d
e Z dS ))Queue SimpleQueue
JoinableQueue N)EmptyFull )
connection)context)debuginfoFinalizeregister_after_fork
is_exitingc e Zd ZddZd Zd Zd ZddZdd
Zdd Z d Z
d
Z d Z d Z
d Zd Zd Zd Zd Zed Zed Zed Zed Zd S ) r r c |dk rddl m} || _ t j d \ | _ | _ | | _ t j
| _ t j
dk rd | _ n| | _ | | | _ d| _ | t j
dk r t' | t( j d S d S )Nr r )
SEM_VALUE_MAXFduplexwin32) synchronizer _maxsizer Pipe_reader_writerLock_rlockosgetpid_opidsysplatform_wlockBoundedSemaphore_sem
_ignore_epipe_resetr r _after_forkselfmaxsizectxs =/opt/alt/python311/lib64/python3.11/multiprocessing/queues.py__init__zQueue.__init__% s a<< = = = = = =
%/_E%B%B%B" dlhhjj Y[[
<7 " " DKK ((**DK((11 "
<7 " " e&7 8 8 8 8 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 sB %%%"DM4< T[$)TZA Ar. c |\ | _ | _ | _ | _ | _ | _ | _ | _ | d S r0 ) r% r r r r r" r$ r r& r) states r, __setstate__zQueue.__setstate__> s= <A : T]DL$,
dk49dj
r. c P t d | d d S )NzQueue._after_fork()T)
after_fork)r r& r2 s r, r' zQueue._after_forkC s+
#$$$ t $$$$$r. Fc n |r| j n*t j t j | _ t j | _ d | _ d | _ d| _
d| _ d | _ | j
j | _ | j j | _ | j j | _ d S NF) _notempty_at_fork_reinit threading Conditionr collectionsdeque_buffer_thread _jointhread_joincancelled_closed_closer
send_bytes _send_bytesr
recv_bytes _recv_bytespoll_poll)r) r9 s r, r& z Queue._resetG s C N * * , , , , & 0 1A1A B BDN"(** # <2 <2\&
r. TNc Z | j rt d| d | j || st | j 5 | j | | j | | j
d d d d S # 1 swxY w Y d S NzQueue z
is closed) rF
ValueErrorr$ acquirer r< rC
_start_threadrB appendnotifyr) objblocktimeouts r, putz Queue.putV s < : 8d 8 8 899 9y 00 J
^ $ $|#""$$$ L $ $ $ N ! ! # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s AB B$'B$c | j rt d| d |rO|M| j 5 | }d d d n # 1 swxY w Y | j n|rt
j |z }| j || st |r3|t
j z
}|
| st n|
st | }| j | j n # | j w xY wt | S rO )
rF rP r rK r$ releasetime monotonicrQ r rM _ForkingPicklerloads)r) rW rX resdeadlines r, getz Queue.getb s < : 8d 8 8 899 9 &W_
)
)&&((
)
)
)
)
)
)
)
)
)
)
)
)
)
)
) I
6 >++g5;&&ug66
& & )9)9 9G ::g.. $ # $ K&&(( !!### ##%%%% ##%%%% $$S)))s AA A 'A=D> >Ec N | j | j j z
S r0 )r r$ _semlock
_get_valuer2 s r, qsizez Queue.qsize| s }ty 1 < < > >>>r. c , | S r0 rM r2 s r, emptyz Queue.empty ::<< r. c > | j j S r0 )r$ rd _is_zeror2 s r, fullz
Queue.full s y!**,,,r. c , | d S r; )rb r2 s r,
get_nowaitzQueue.get_nowait s xx r. c . | |d S r; )rY r) rV s r,
put_nowaitzQueue.put_nowait s xxU###r. c L d| _ | j }|rd | _ | d S d S )NT)rF rG )r) closes r, rt z Queue.close s8 DK EGGGGG r. c t d | j s J d | | j r| d S d S )NzQueue.join_thread()zQueue {0!r} not closed)r rF formatrD r2 s r, join_threadzQueue.join_thread sb
#$$$|BB 5 < <T B BBB| r. c t d d| _ | j d S # t $ r Y d S w xY w)NzQueue.cancel_join_thread()T)r rE rD cancelAttributeErrorr2 s r, cancel_join_threadzQueue.cancel_join_thread s[
*+++ " # # % % % % % DD s 3
A Ac t d | j t j t
j | j | j | j | j | j
j | j j | j
| j | j f d | _ d| j _ t d | j t d | j s?t) | j t
j t- j | j gd | _ t) | t
j | j | j gd | _ d S )
NzQueue._start_thread()QueueFeederThread)targetargsnameTzdoing 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 daemonstartrE r
_finalize_joinweakrefrefrD _finalize_closerG r2 s r, rR zQueue._start_thread s2
%&&&
';,0@+t| 14<3E$d&A) %
#
*+++
-..." ' e 2T\**+ D %'
\4> * r. c t d | }|%| t d d S t d d S )Nzjoining queue threadz... queue thread joinedz ... queue thread already dead)r join)twrthreads r, r zQueue._finalize_join sY
$%%% KKMMM + , , , , , 1 2 2 2 2 2r. c t d |5 | t | d d d d S # 1 swxY w Y d S )Nz telling queue thread to quit)r rS _sentinelrT )buffernotemptys r, r zQueue._finalize_close s
,---
MM) $ $ $ OO s /AAAc T t d |j } |j }
|j } | j } t
}
t j dk r|j }|j }nd } | | s
| |
n# |
w xY w | }||
u r%t d | | d S t | }| || n0 | || | n# | w xY w# t $ r Y nw xY wn# t $ ru}|r%t |dd t j k rY d }~d S t rt! d| Y d }~d S | ||| Y d }~nd }~ww xY wU)Nz$starting thread to feed data to piper r z%feeder thread got sentinel -- exitingerrnor zerror in queue thread: %s)r rQ r[ waitpopleftr r r! r^ dumps
IndexError Exceptiongetattrr EPIPEr r )r r rH writelock reader_close writer_close ignore_epipeonerror queue_semnacquirenreleasenwaitbpopleftsentinelwacquirewreleaserV es r, r z Queue._feed s$ 4555##
> <7 " " (H (HHH. $-
$
! HJJJJHHJJJJ+ &hjj (?? !"I J J J (LNNN (LNNN "F . 3 3C 8 8#+ &JsOOOO $HJJJ + *
3 (
#+$ " D
$
$
$ GAw$:$:ek$I$IFFFFF
<<
$4a888FFFFF %%'''GAsOOOOOOOO#
$;. $sx
D& ! A8 - D& 8 BD& 2D <2D / D : D DD
D" D& !D""D& &
F%0!F F ; F F%c 6 ddl }| dS )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 z Queue._on_queue_feeder_error s( r. r )FTN)__name__
__module__ __qualname__r- r3 r7 r' r& rY rb rf ri rm ro rr rt rw r{ rR staticmethodr r r r r. r, r r # s 9 9 9 9(A A A
% % %
'
'
'
'
$
$
$
$* * * *4? ? ? - - - $ $ $ B 3 3 \3 \ <$ <$ \<$| \ r. r c 6 e Zd Zd
dZd Zd Zd dZd Zd ZdS ) r r c t | || | d | _ | | _ d S )N)r+ r )r r- Semaphore_unfinished_tasksr? _condr( s r, r- zJoinableQueue.__init__( sA
tW#...!$ q!1!1 ]]__
r. c T t | | j | j fz S r0 )r r3 r r r2 s r, r3 zJoinableQueue.__getstate__- s% !!$''4:t7M*NNNr. c z t | |d d |dd \ | _ | _ d S )N)r r7 r r r5 s r, r7 zJoinableQueue.__setstate__0 s=
4ss,,,-2233Z*
D***r. TNc | j rt d| d | j || st | j 5 | j 5 | j | | j
| | j | j
d d d n # 1 swxY w Y d d d d S # 1 swxY w Y d S rO )rF rP r$ rQ r r< r rC rR rB rS r r[ rT rU s r, rY zJoinableQueue.put4 sf < : 8d 8 8 899 9y 00 J
^ $ $TZ $ $|#""$$$ L $ $ $ " * * , , , N ! ! # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s7 C A(C 4 C C CC CC C c | j 5 | j d st d | j j r| j d d d d S # 1 swxY w Y d S )NFz!task_done() called too many times)r r rQ rP rd rl
notify_allr2 s r, task_donezJoinableQueue.task_doneA s
Z ( ()11%88
F !DEEE%.7799
(
%%''' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s A!A66A:=A:c | j 5 | j j s| j d d d d S # 1 swxY w Y d S r0 )r r rd rl r r2 s r, r zJoinableQueue.joinH s
Z " ")2;;==
"
!!! " " " " " " " " " " " " " " " " " "s 8A
AAr r ) r r r r- r3 r7 rY r r r r. r, r r & s{ % % % %
O O O8 8 8 $ $ $ $( ( (" " " " "r. r c X e Zd Zd Zd Zd Zd Zd Zd Zd Z e
e j Z
dS ) r c t j d \ | _ | _ | | _ | j j | _ t j dk r d | _
d S | | _
d S )NFr r ) r r r r r r rL rM r r! r" )r) r+ s r, r- zSimpleQueue.__init__S sc %/_E%B%B%B" dlhhjj \&
<7 " " DKKK ((**DKKKr. c j | j | j d S r0 )r rt r r2 s r, rt zSimpleQueue.close\ s0 r. c , | S r0 rh r2 s r, ri zSimpleQueue.empty` rj r. c ^ t j | | j | j | j | j fS r0 )r
r1 r r r r" r2 s r, r3 zSimpleQueue.__getstate__c s* %%% dlDKEEr. c ^ |\ | _ | _ | _ | _ | j j | _ d S r0 )r r r r" rL rM r5 s r, r7 zSimpleQueue.__setstate__g s( AF> t|T[$+\&
r. c | j 5 | j }d d d n # 1 swxY w Y t | S r0 )r r rJ r^ r_ )r) r` s r, rb zSimpleQueue.getk s
[ , ,,))++C , , , , , , , , , , , , , , , $$S)))s .22c t | }| j | j | d S | j 5 | j | d d d d S # 1 swxY w Y d S r0 )r^ r r" r rH rq s r, rY zSimpleQueue.putq s ##C(( ; L # #C ( ( ( ( (
-
- '',,,
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-s A--A14A1N)r r r r- rt ri r3 r7 rb rY classmethodtypes GenericAlias__class_getitem__r r. r, r r Q s % % % F F F' ' '* * * - - - $ E$677r. r ) __all__r r r> r@ r\ r r r queuer r _multiprocessing r r
reductionForkingPicklerr^ utilr r r
r r objectr r r r r r. r, <module>r s| 4
3
3
#2 H H H H H H H H H H H H H H v v v v v F v v v r
FHH %" %" %" %" %"E %" %" %"V*8 *8 *8 *8 *8& *8 *8 *8 *8 *8r.