Edit File: thread.cpython-36.opt-1.pyc
3 �P\� � @ s> d Z ddlZddlZddljZddlmZ G dd� de�Z dS )z*Module containing the SessionThread class.� N� )�queuec @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )� SessionThreadc C s$ || _ || _| j� || _|| _d S )N)�_session�_jobs�_create_worker� _responses� _exceptions)�selfZinitialized_sessionZ job_queueZresponse_queueZexception_queue� r � /usr/lib/python3.6/thread.py�__init__ s zSessionThread.__init__c C s4 t j| jtj� d�| _d| j_d| j_| jj� d S )N)�target�nameTr ) � threadingZThread� _make_request�uuidZuuid4�_workerZdaemonZ_state�start)r r r r r s z SessionThread._create_workerc C sn z\y| j jf |�}W n4 tjk rH } z| jj||f� W Y d d }~X nX | jj||f� W d | jj� X d S )N) r Zrequest�excZRequestExceptionr Zputr r Z task_done)r �kwargsZresponse�er r r �_handle_request s "z SessionThread._handle_requestc C s< x6y| j j� }W n tjk r( P Y nX | j|� qW d S )N)r Z get_nowaitr ZEmptyr )r r r r r r & s zSessionThread._make_requestc C s | j j� S )z*Proxy to the thread's ``is_alive`` method.)r �is_alive)r r r r r / s zSessionThread.is_alivec C s | j j� dS )z&Join this thread to the master thread.N)r �join)r r r r r 3 s zSessionThread.joinN) �__name__� __module__� __qualname__r r r r r r r r r r r s r ) �__doc__r r Zrequests.exceptions� exceptionsr Z_compatr �objectr r r r r �<module> s
Back to File Manager