File: //usr/lib/python3.6/site-packages/requests_toolbelt/threaded/__pycache__/thread.cpython-36.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