← Back
Editing: thread.cpython-38.pyc
U �ˀX� � @ s@ d Z ddlZddlZddlmZ ddlmZ 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$ || _ || _| �� || _|| _d S �N)�_session�_jobs�_create_worker� _responses� _exceptions)�selfZinitialized_sessionZ job_queueZresponse_queueZexception_queue� r �C/usr/lib/python3/dist-packages/requests_toolbelt/threaded/thread.py�__init__ s zSessionThread.__init__c C s4 t j| jt�� d�| _d| j_d| j_| j�� 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\z| jjf |�}W n4 tjk rH } z| j�||f� W 5 d }~X Y nX | j�||f� W 5 | j �� X d S r ) r Z task_doner Zrequest�excZRequestExceptionr Zputr )r �kwargsZresponse�er r r �_handle_request s "z SessionThread._handle_requestc C s: z| j �� }W n tjk r( Y q6Y nX | �|� q d S r )r Z get_nowaitr ZEmptyr )r r r r r r & s zSessionThread._make_requestc C s | j �� S )z*Proxy to the thread's ``is_alive`` method.)r �is_aliver r r r r / s zSessionThread.is_alivec C s | j �� dS )z&Join this thread to the master thread.N)r �joinr 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
Save File
Cancel