Recipe 577526 revision 1

#####################
# source/exe_queue.py
#####################

import queue

################################################################################

class Pipe:

    def __init__(self, obj):
        self.__obj = obj
        self.__queue = queue.Queue()

    def __getattr__(self, name):
        method = _Method(self.__queue, name)
        setattr(self, name, method)
        return method

    def update(self):
        while not self.__queue.empty():
            name, args, kwargs = self.__queue.get()
            getattr(self.__obj, name)(*args, **kwargs)

################################################################################

class _Method:

    def __init__(self, queue, name):
        self.__queue = queue
        self.__name = name

    def __call__(self, *args, **kwargs):
        self.__queue.put((self.__name, args, kwargs))

• « Back to Recipe 577526

History

• revision 1 (13 years ago)