관리-도구
편집 파일: worker.cpython-38.pyc
U ��\� � @ s^ d dl Z d dlmZmZ d dlmZmZ d dlmZmZ d dl m Z e� ZG dd� de�ZdS )� N)�Thread�Lock)�sleep�time)�queue�check_thread_support)�loggerc @ sb e Zd Zdd� Zedd� �Zdd� Zdd� Zd d � Zd d � Z ddd�Z dd� Z dd� Z dd� Z d S )�BackgroundWorkerc C s* t � t�d�| _t� | _d | _d | _d S )N���)r r �Queue�_queuer �_lock�_thread�_thread_for_pid��self� r �B/opt/alt/python38/lib/python3.8/site-packages/sentry_sdk/worker.py�__init__ s zBackgroundWorker.__init__c C s& | j t�� krdS | js dS | j�� S )NF)r �os�getpidr �is_aliver r r r r s zBackgroundWorker.is_alivec C s | j s| �� d S �N)r �startr r r r �_ensure_thread$ s z BackgroundWorker._ensure_threadc C sd t � | }| j}|j�� z8|jrL|t � }|dkr<W � dS |jj|d� q W �dS |j�� X d S )Nr F)�timeoutT)r r Zall_tasks_done�acquire�releaseZunfinished_tasks�wait)r r Zdeadliner �delayr r r �_timed_queue_join) s z"BackgroundWorker._timed_queue_joinc C sL | j �< | js>t| jdd�| _| j�d� | j�� t�� | _ W 5 Q R X d S )Nz raven-sentry.BackgroundWorker)�target�nameT) r r r �_targetr � setDaemonr r r r r r r r r 8 s � zBackgroundWorker.startc C s> t �d� | j�$ | jr0| j�t� d | _d | _W 5 Q R X d S )Nz"background worker got kill request)r �debugr r r � put_nowait� _TERMINATORr r r r r �killC s zBackgroundWorker.killNc C sD t �d� | j� | jr,|dkr,| �||� W 5 Q R X t �d� d S )Nz#background worker got flush requestg zbackground worker flushed)r r% r r � _wait_flush)r r �callbackr r r �flushL s zBackgroundWorker.flushc C sN t d|�}| �|�sJ| j�� }t�d|� |d k r<|||� | �|| � d S )Ng�������?z %d event(s) pending on flush)�minr r Zqsizer r% )r r r* Zinitial_timeout�pendingr r r r) T s z BackgroundWorker._wait_flushc C s | � � | j�|� d S r )r r r& �r r* r r r �submit^ s zBackgroundWorker.submitc C sf | j �� }z@|tkrW �4qbz |� W n" tk rF tjddd� Y nX W 5 | j �� X td� q d S )NzFailed processing jobT)�exc_infor )r �getZ task_doner' � Exceptionr �errorr r. r r r r# c s zBackgroundWorker._target)N)�__name__� __module__� __qualname__r �propertyr r r r r( r+ r) r/ r# r r r r r s r )r � threadingr r r r Zsentry_sdk._compatr r Zsentry_sdk.utilsr r ZAny�Optional�Callable�objectr' r r r r r �<module> s