Как сделать выполнение функции как Event-событие?

Question

[Сергей Ермаков]

Здравствуйте, подскажите пожалуйста.

# file1.py

class TEMP1(object):
    def __init__(self): pass
    def func1(self, *a, **k):
        print 'TEMP1 > func1'
        
t1 = TEMP1()
        
# file2.py

#from file1 import TEMP1

def decorate(function):
    print 'start decorate'
    def wrap(*a, **k):
        print 'start wrap'
        return function(*a, **k)
    return wrap

@decorate
def new_func1(*a, **k):
    old_func1(*a, **k)
    print 'hook: new_func1'
    
old_func1 = TEMP1.func1
TEMP1.func1 = new_func1

def myFunc():
    print 'myFunc'

t1.func1()

Как в функции decorate определить нашу function как Event (если я правильно понимаю), чтобы к ней можно было прописать function += myFunc?

Answer 1

[Vindicar]

Погоди-погоди-погоди... если я правильно понимаю, ты хочешь создать класс со следующими свойствами:
1. Экземпляры класса должны хранить в себе список пользовательских callback-функций с одинаковой сигнатурой.
2. При вызове экземпляра этого класса (как callable object), все callback-функции должны быть вызваны поочерёдно.
3. Добавить и удалить новый callback должно быть можно посредством операторов += и -=.
Я верно понял? Тогда мне неясно причем тут декоратор, и что должна будет делать декорируемая функция.

Я бы написал что-то в духе:

class EventCaller:
    #конструктор
    def __init__(self):
        #поскольку мы не планируем позволять двойную подписку, то у нас будет множество, а не список.
        self.__callbacks = set();
    # магический метод перегрузки оператора +=
    def __iadd__(self, callback):
        #проверка, что нам вообще передали callable object
        if not callable(callback):
            raise Exception("Callback object is not callable")
        #эта проверка не позволяет подписаться дважды одним объектом
        if callback in self.__callbacks:
            raise Exception("Double event subscription")
        self.__callbacks.add(callback)
    #магический метод перегрузки оператора -=
    def __isub__(self, callback):
        if callback not in self.__callbacks:
            raise Exception("No such event handler")
        self.__callbacks.remove(callback)
    #магический метод, позволяющий вызывать экземпляр объекта как функцию
    #аргументы, переданные методу, сохраняются как есть
    #неименованные - в кортеже args, именованные - в словаре kwargs
    def __call__(self, *args, **kwargs):
        for callback in self.__callbacks:
            try:
                callback(*args, **kwargs)
            except:
                pass

Вот черновик такого класса. Он, конечно, нуждается в доработке:
а) стоит добавить потоко-безопасную работу со списком обработчиков. Возможно, заменить список на потоко-безопасное хранилище.
б) стоит запоминать выкинутые обработчиками исключения, и сообщать о них тем или иным способом (перевыбрасывать? выбрасывать своё исключение со списком всех произошедших?)
в) так что если один из обработчиков изменит переданные объекты, это повлияет на последующие. Если такое поведение надо избежать, возможно, стоит создавать отдельную глубокую копию (см. модуль copy) args и kwargs для каждого обработчика. Хотя там свои заморочки.

Пример использования:

#простой обработчик, печатающий переданные ему аргументы
def evthandler(*args, **kwargs):
    print "Unnamed arguments are:", args
    print "Named arguments are:", kwargs
#
#создаем объект-событие
evt = EventCaller()
#подписываемся на него
evt += evthandler
#генерируем событие. Аргументы могут быть произвольными, они будут переданы обработчикам как есть
evt("unnamed arg 1", "unnamed arg 2", kwarg1=True, kwarg2=42)
#отписываемся
evt -= evthandler
#этот вызов не будет иметь эффекта, так как список обработчиков события пуст
evt("unnamed arg 1", "unnamed arg 2", kwarg1=True, kwarg2=42)

За синтаксическую правильность кода не ручаюсь, но идея должна быть ясна.

Comments

[Сергей Ермаков]

Вы не поняли. Мне нужно в декораторе определить аргумент function как Event, чтобы на следующей строке прописать += myFunc.

[Vindicar]

Сергей Ермаков: Я и сейчас не понял. Можешь перефразировать? Что значит "определить аргумент как Event"?

[Сергей Ермаков]

Vindicar:
>>> Что значит "определить аргумент как Event"?
Переопределить принимаемый function (def decorate(function):), чтобы можно было прописать function += myFunc, иначе ошибка выводится

<<< TypeError: unsupported operand type(s) for +=: 'function' and 'function'

[Vindicar]

Сергей Ермаков: Можешь пояснить, какого поведения ты хочешь этим добиться? У нас есть три функции - исходная (декорируемая), задекорированная (которую мы создаём на базе исходной), и обработчик, который мы цепляем через +=. Как они должны между собой взаимодействовать?
Я имею ввиду, в декораторе, ты можешь заменить декорируемую функцию объектом по типу того что я описал: обладающим методами __iadd__/__isub__ для обработки операторов +=/-= и методом __call__, в котором будет вызываться декорируемая функция. Но какой конкретно функциональности ты хочешь добиться? Без этого не понять, что должно быть в __iadd__/__isub__.

[Vindicar]

Сергей Ермаков: Погоди, кажется понял: ты хочешь получать оповещения, что функция была вызвана, при этом остальное поведение функции не должно измениться?

[Сергей Ермаков]

Vindicar: Мне просто нужно к декорируемой функции (аргументу function) выполнить аттач += myFunc, при выполнение ошибка TypeError: unsupported operand type(s) for +=: ‘function’ and ‘function’. Все

[Сергей Ермаков]

Vindicar: У меня есть СЛОВАРЬ, в нем {class: function, ..}, я ловлю функцию стороннюю и к ней хочу приатачить мои функции из СЛОВАРЯ, через my_hook_func += myFunc1, .. += myFunc2, ..

[Vindicar]

Сергей Ермаков: Что значит "приаттачить"? В Питоне нет такого понятия. Ты хочешь чтобы эти функции вызывались последовательно при каждом вызове исходной функции?
TypeError тебе Питон выдаёт совершенно правильно, для функций операция += не определена вообще. Можно самому написать нужную функциональность, но для этого надо понять в чем она заключается.

[Сергей Ермаков]

Vindicar: Помогите ее определить >>>для функций операция += не определена вообще

[Vindicar]

И какой результат должен быть у этой операции? Что должно получиться в итоге? Я уже который комментарий пытаюсь это выяснить.