3
P\ @ s> d Z ddlZddlZddljZddlmZ G dd deZ 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)targetnameTr ) threadingZThread
_make_requestuuidZuuid4_workerZdaemonZ_statestart)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 ZrequestexcZRequestExceptionr Zputr r Z task_done)r
kwargsZresponseer 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 s