⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.19
Server IP:
41.128.143.86
Server:
Linux host.raqmix.cloud 6.8.0-1025-azure #30~22.04.1-Ubuntu SMP Wed Mar 12 15:28:20 UTC 2025 x86_64
Server Software:
Apache
PHP Version:
8.3.23
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
opt
/
plesk
/
python
/
3
/
lib
/
python3.10
/
__pycache__
/
View File Name :
queue.cpython-310.opt-2.pyc
o SWV @ s d dl Z d dlZd dlmZ d dlmZmZ d dlmZ zd dl m Z W n e y0 dZ Y nw g dZ zd dl m Z W n e yN G dd d eZ Y nw G d d d eZG d d d ZG dd deZG dd deZG dd dZe du r}eZ dS dS ) N)deque)heappushheappop) monotonic) SimpleQueue)EmptyFullQueue PriorityQueue LifoQueuer )r c @ e Zd Z dS )r N__name__ __module__ __qualname__ r r +/opt/plesk/python/3/lib/python3.10/queue.pyr r c @ r )r Nr r r r r r r r c @ s e Zd Z d ddZdd Zdd Zdd Zd d Zd d Zd!ddZ d!ddZ dd Z dd Z dd Z dd Zd d Zd d ZeejZdS )"r r c C sN || _ | | t | _t| j| _t| j| _t| j| _d| _ d S Nr ) maxsize_init threadingLockmutex Condition not_emptynot_fullall_tasks_doneunfinished_tasksselfr r r r __init__" s zQueue.__init__c C s` | j " | jd }|dkr|dk rtd| j || _W d d S 1 s)w Y d S )N r z!task_done() called too many times)r r ValueError notify_all)r unfinishedr r r task_done9 s "zQueue.task_donec C sT | j | jr| j | jsW d d S W d d S 1 s#w Y d S N)r r waitr r r r joinO s "z Queue.joinc C s4 | j | W d S 1 sw Y d S r' r _qsizer) r r r qsize\ s $z Queue.qsizec C s6 | j | W d S 1 sw Y d S r' r+ r) r r r emptya s $z Queue.emptyc C sJ | j d| j k o| kn W d S 1 s w Y d S r )r r r, r) r r r fullo s $z Queue.fullTNc C s | j o | jdkrZ|s| | jkrtnD|d u r.| | jkr-| j | | jks!n,|dk r6tdt | }| | jkrZ|t }|dkrMt| j | | | jksB| | | jd7 _| j W d d S 1 svw Y d S )Nr ''timeout' must be a non-negative number r" ) r r r, r r( r# time_putr r notify)r itemblocktimeoutendtime remainingr r r putz s2 "z Queue.putc C s | j T |s| s tn8|d u r | s | j | rn&|dk r(tdt | }| sF|t }|dkr<t| j | | r1| }| j |W d S 1 s[w Y d S )Nr r0 r1 ) r r, r r( r# r2 _getr r4 )r r6 r7 r8 r9 r5 r r r get s0 $z Queue.getc C | j |ddS NF)r6 r: r r5 r r r put_nowait zQueue.put_nowaitc C | j ddS r> r< r) r r r get_nowait zQueue.get_nowaitc C s t | _d S r' )r queuer r r r r s z Queue._initc C t | jS r' lenrG r) r r r r, z Queue._qsizec C | j | d S r' rG appendr@ r r r r3 z Queue._putc C | j S r' )rG popleftr) r r r r; rK z Queue._get)r TN)r r r r! r& r* r- r. r/ r: r< rA rE r r, r3 r; classmethodtypes GenericAlias__class_getitem__r r r r r s" r c @ . e Zd Z dd Zdd Zdd Zdd Zd S ) r c C g | _ d S r' rG r r r r r rK zPriorityQueue._initc C rH r' rI r) r r r r, rK zPriorityQueue._qsizec C s t | j| d S r' )r rG r@ r r r r3 rO zPriorityQueue._putc C rH r' )r rG r) r r r r; rK zPriorityQueue._getNr r r r r, r3 r; r r r r r s r c @ rW ) r c C rX r' rY r r r r r rK zLifoQueue._initc C rH r' rI r) r r r r, rK zLifoQueue._qsizec C rL r' rM r@ r r r r3 rO zLifoQueue._putc C rP r' )rG popr) r r r r; rK zLifoQueue._getNrZ r r r r r s r c @ sT e Zd Z dd ZdddZdddZd d Zd d Zd d Zdd Z e e j Z dS )_PySimpleQueuec C s t | _td| _d S r )r _queuer Semaphore_countr) r r r r! s z_PySimpleQueue.__init__TNc C s | j | | j d S r' )r] rN r_ release)r r5 r6 r7 r r r r: s z_PySimpleQueue.putc C s6 |d ur |dk r t d| j||st| j S )Nr r0 )r# r_ acquirer r] rQ )r r6 r7 r r r r< s z_PySimpleQueue.getc C r= r> r? r@ r r r rA * rB z_PySimpleQueue.put_nowaitc C rC r> rD r) r r r rE 2 rF z_PySimpleQueue.get_nowaitc C s t | jdkS r rJ r] r) r r r r. : s z_PySimpleQueue.emptyc C s t | jS r' rb r) r r r r- > s z_PySimpleQueue.qsizerR )r r r r! r: r< rA rE r. r- rS rT rU rV r r r r r\ s r\ )r rT collectionsr heapqr r r2 r r] r ImportError__all__r Exceptionr r r r r\ r r r r <module> s4 DC