Server: appserver-7f0f8755-nginx-15961cad18524ec5a9db05f2a6a7e440
Current directory: /usr/lib/python2.7/multiprocessing
Software: nginx/1.27.5
Shell Command
Create a new file
Upload file
File: queues.pyc
� ӫ[c @ s> d d d g Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z d d l Z d d l m Z d d l m Z m Z m Z m Z d d l m Z m Z m Z m Z m Z d d l m Z d e f d � � YZ e � Z d e f d � � YZ d e f d � � YZ d S( t Queuet SimpleQueuet JoinableQueuei����N( t Emptyt Fulli ( t Pipe( t Lockt BoundedSemaphoret Semaphoret Condition( t debugt infot Finalizet register_after_forkt is_exiting( t assert_spawningc B s� e Z d d � Z d � Z d � Z d � Z e d d � Z e d d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z e d � � Z e d � � Z e d � � Z RS( i c C s� | d k r t j j } n | | _ t d t � \ | _ | _ t � | _ t j � | _ t j d k ru d | _ n t � | _ t | � | _ | j � t j d k r� t | t j � n d S( Ni t duplext win32( t _multiprocessingt SemLockt SEM_VALUE_MAXt _maxsizeR t Falset _readert _writerR t _rlockt ost getpidt _opidt syst platformt Nonet _wlockR t _semt _after_forkR R ( t selft maxsize( ( s, /usr/lib/python2.7/multiprocessing/queues.pyt __init__: s c C s8 t | � | j | j | j | j | j | j | j f S( N( R R R R R R R! R ( R# ( ( s, /usr/lib/python2.7/multiprocessing/queues.pyt __getstate__L s c C s> | \ | _ | _ | _ | _ | _ | _ | _ | j � d S( N( R R R R R R! R R" ( R# t state( ( s, /usr/lib/python2.7/multiprocessing/queues.pyt __setstate__Q s 0c C s� t d � t j t j � � | _ t j � | _ d | _ d | _ t | _ t | _ d | _ | j j | _ | j j | _ | j j | _ d S( Ns Queue._after_fork()( R t threadingR R t _notemptyt collectionst dequet _bufferR t _threadt _jointhreadR t _joincancelledt _closedt _closeR t sendt _sendR t recvt _recvt pollt _poll( R# ( ( s, /usr/lib/python2.7/multiprocessing/queues.pyR" V s c C s� | j s t � | j j | | � s. t � n | j j � z= | j d k rZ | j � n | j j | � | j j � Wd | j j � Xd S( N( R1 t AssertionErrorR! t acquireR R* R. R t _start_threadR- t appendt notifyt release( R# t objt blockt timeout( ( s, /usr/lib/python2.7/multiprocessing/queues.pyt putc s c C s | rT | d k rT | j j � z! | j � } | j j � | SWd | j j � Xn� | rm t j � | } n | j j | | � s� t � n zt | r� | t j � } | d k s� | j | � r� t � q� n | j � s� t � n | j � } | j j � | SWd | j j � Xd S( Ni ( R R R: R6 R! R> t timeR R8 ( R# R@ RA t rest deadline( ( s, /usr/lib/python2.7/multiprocessing/queues.pyt getq s, c C s | j | j j j � S( N( R R! t _semlockt _get_value( R# ( ( s, /usr/lib/python2.7/multiprocessing/queues.pyt qsize� s c C s | j � S( N( R8 ( R# ( ( s, /usr/lib/python2.7/multiprocessing/queues.pyt empty� s c C s | j j j � S( N( R! RG t _is_zero( R# ( ( s, /usr/lib/python2.7/multiprocessing/queues.pyt full� s c C s | j t � S( N( RF R ( R# ( ( s, /usr/lib/python2.7/multiprocessing/queues.pyt get_nowait� s c C s | j | t � S( N( RB R ( R# R? ( ( s, /usr/lib/python2.7/multiprocessing/queues.pyt put_nowait� s c C sD t | _ z | j j � Wd | j } | r? d | _ | � n Xd S( N( t TrueR1 R t closeR2 R ( R# RP ( ( s, /usr/lib/python2.7/multiprocessing/queues.pyRP � s c C s3 t d � | j s t � | j r/ | j � n d S( Ns Queue.join_thread()( R R1 R9 R/ ( R# ( ( s, /usr/lib/python2.7/multiprocessing/queues.pyt join_thread� s c C s<