Gecko [ theprintave.ca ]

Linux webserver 6.8.0-49-generic #49~22.04.1-Ubuntu SMP PREEMPT_DYNAMIC Wed Nov 6 17:42:15 UTC 2 x86_64
Apache/2.4.52 (Ubuntu)
Server IP : 192.168.1.1 & Your IP : 3.129.194.130
Domains : Cant Read [ /etc/named.conf ]
User : www-data

Name	Size	Permission	Date
__pycache__	[ DIR ]	drwxr-xr-x	2024-11-28 06:59
test	[ DIR ]	drwxr-xr-x	2024-11-28 06:59
__init__.py	505 B	-rw-r--r--	2022-02-07 13:12
_convenience.py	894 B	-rw-r--r--	2022-02-07 13:12
_ithreads.py	1.7 KB	-rw-r--r--	2022-02-07 13:12
_memory.py	1.56 KB	-rw-r--r--	2022-02-07 13:12
_pool.py	2.21 KB	-rw-r--r--	2022-02-07 13:12
_team.py	6.98 KB	-rw-r--r--	2022-02-07 13:12
_threadworker.py	3.21 KB	-rw-r--r--	2022-02-07 13:12

Rename

# -*- test-case-name: twisted._threads.test -*-
# Copyright (c) Twisted Matrix Laboratories.
# See LICENSE for details.

"""
Interfaces related to threads.
"""

from zope.interface import Interface

class AlreadyQuit(Exception):
    """
    This worker worker is dead and cannot execute more instructions.
    """

class IWorker(Interface):
    """
    A worker that can perform some work concurrently.

All methods on this interface must be thread-safe.
    """

def do(task):
        """
        Perform the given task.

As an interface, this method makes no specific claims about concurrent
        execution.  An L{IWorker}'s C{do} implementation may defer execution
        for later on the same thread, immediately on a different thread, or
        some combination of the two.  It is valid for a C{do} method to
        schedule C{task} in such a way that it may never be executed.

It is important for some implementations to provide specific properties
        with respect to where C{task} is executed, of course, and client code
        may rely on a more specific implementation of C{do} than L{IWorker}.

@param task: a task to call in a thread or other concurrent context.
        @type task: 0-argument callable

@raise AlreadyQuit: if C{quit} has been called.
        """

def quit():
        """
        Free any resources associated with this L{IWorker} and cause it to
        reject all future work.

@raise AlreadyQuit: if this method has already been called.
        """

class IExclusiveWorker(IWorker):
    """
    Like L{IWorker}, but with the additional guarantee that the callables
    passed to C{do} will not be called exclusively with each other.
    """