← Back
Editing: _memory.cpython-38.pyc
U W[� � @ sf d Z ddlmZmZmZ ddlmZ ddlmZ ddl m Z e � Z ee�G dd� de ��Z d d � Zd S ) z> Implementation of an in-memory worker that defers execution. � )�absolute_import�division�print_function)� implementer� )�IWorker)�Quitc @ s, e Zd ZdZefdd�Zdd� Zdd� ZdS ) � MemoryWorkerz| An L{IWorker} that queues work for later performance. @ivar _quit: a flag indicating @type _quit: L{Quit} c C s t � | _|� | _dS )z+ Create a L{MemoryWorker}. N)r �_quit�_pending)�self�pending� r �:/usr/lib/python3/dist-packages/twisted/_threads/_memory.py�__init__ s zMemoryWorker.__init__c C s | j �� | j�|� dS )z} Queue some work for to perform later; see L{createMemoryWorker}. @param work: The work to perform. N)r Zcheckr �append)r Zworkr r r �do# s zMemoryWorker.doc C s | j �� | j�t� dS )z# Quit this worker. N)r �setr r � NoMoreWork)r r r r �quit- s zMemoryWorker.quitN)�__name__� __module__� __qualname__�__doc__�listr r r r r r r r s r c s � fdd�} t � � � | fS )a Create an L{IWorker} that does nothing but defer work, to be performed later. @return: a worker that will enqueue work to perform later, and a callable that will perform one element of that work. @rtype: 2-L{tuple} of (L{IWorker}, L{callable}) c s. � j s dS � j d tkr dS � j �d�� dS )NFr T)r r �popr �Zworkerr r �perform? s z#createMemoryWorker.<locals>.perform)r )r r r r �createMemoryWorker6 s r N)r Z __future__r r r Zzope.interfacer � r Z _conveniencer �objectr r r r r r r �<module> s #
Save File
Cancel