Это так сломано, надеюсь, вы со мной милостивы:
reactor.callLater(0, myFunction, parameter1).addCallback(reactor.stop)
reactor.run()
myFunction возвращает отложенную.
Я надеюсь, что это ясно, что я хочу сделать:
myFunction. Вот почему я использую 0 в качестве параметра задержки. Нет другого способа, кроме callLater? Это выглядит смешно, чтобы передать ему задержку 0.myFunction выполнит задачу.Проблемы, которые у меня есть до сих пор:
AttributeError: DelayedCall instance has no attribute 'addCallback'. Справедливо! Как поместить обратный вызов в цепочку обратного вызова, начатую myFunction, затем?exceptions.TypeError: stop() takes exactly 1 argument (2 given).Чтобы решить вторую проблему, мне пришлось определить специальную функцию:
def stopReactor(result):
gd.log.info( 'Result: %s' % result)
gd.log.info( 'Stopping reactor immediatelly' )
reactor.stop()
И измените код на:
reactor.callLater(0, myFunction, parameter1).addCallback(stopReactor)
reactor.run()
(все еще не работает из-за проблемы callLater, но stopReactor будет работать сейчас)
Нет ли другого способа вызова reactor.stop за исключением определения дополнительной функции?
IReactorTime.callLater и Deferred смешиваются вместе twisted.internet.task.deferLater.
from twisted.internet import reactor, task
d = task.deferLater(reactor, 0, myFunction, parameter1)
d.addCallback(lambda _: reactor.stop())
reactor.run()
Я хочу остановить реактор, как только myFunction выполнит задачу.
Итак, создайте обертку, которая работает myFunction, а затем остановит реактор?
def wrapper(reactor, *args):
myFunction(*args)
reactor.stop()
reactor.callLater(0, wrapper, reactor, ...)
Вам нужно приложить обратный вызов к отложенному, который возвращает myFunction, поскольку callLater не возвращает функцию. Возможно, что-то подобное:
reactor.callLater(0, lambda: myFunction(parameter1).addCallback(lambda _: reactor.stop())
Но это не проверено.
Вам нужно написать новую функцию (здесь лямбда _: reactor.stop()), потому что обратные вызовы к отложенному всегда принимают результат до этого. Если вы обнаружите, что хотите использовать обратные вызовы для своих побочных эффектов, и вы часто не заботитесь о распространении значений, вы можете определить небольшую вспомогательную функцию:
def ignoringarg(f):
return lambda _: f()
И затем выполните:
reactor.callLater(0, lambda: myFunction(paramater1).addCallback(ignoringarg(reactor.stop)))
(То, что было бы действительно аккуратно, было бы определить __rshift__ (и локальный аналог) для класса Deferred, чтобы вы могли сделать: myFunction(parameter1) >> reactor.stop, когда вы хотите отказаться от аргумента или myFunction(parameter1) >>= someotherfunc, если вы хотите распространять аргумент. Если вы считаете, что злоупотребление синтаксисом haskellish является "опрятным", во всяком случае.)
Если вам нужно активировать обратный вызов с каким-либо действием, просто сделайте это (возможно, нет необходимости возвращать отложенную или smth). Просто, чтобы прояснить ситуацию (используя чисто отложенные):
from twisted.internet import reactor, defer
# That will be our deferred to play with
# it has callback and errback methods
d = defer.Deferred()
def my_function(x):
print 'function', x
# need to trigger deferred upon function run?
# Lets tell it to do so:
d.callback(x)
# That our callback to run after triggering `d`
def d_callback(y):
print 'callback ', y
# now let bind that callback to be actually launched by `d`
d.addCallback(d_callback)
# now adding another callback just to stop reactor
# note lambda simply helps to agree number of arguments
d.addCallback(lambda data: reactor.stop())
# so we'll call `my_function` in 2 secs, then it runs
# then it triggers `d` to fire its callbacks
# then `d` actually detonates the whole chain of its added callbacks
reactor.callLater(2, my_function, 'asdf') # 'asdf' is some stupid param
# Here how it works
print 'Lets start!'
reactor.run()
print 'Done!'