Слабые обратные вызовы Python и порядок выполнения __del__ - PullRequest
Новая
       12

Слабые обратные вызовы Python и порядок выполнения __del__

4 голосов
/ 04 августа 2009

Есть ли в Python способ вызова функции после завершения объекта?

Я думал, что обратный вызов в слабой ссылке сделает это, но кажется, что обратный вызов слабой ссылки вызывается после того, как объект собран мусором, но до вызова метода __del__ объектов. Кажется, это противоречит заметкам о слабых местах и ​​сборке мусора в магистрали Python . Вот пример. 

import sys
import weakref

class Spam(object) :
  def __init__(self, name) :
    self.name = name

  def __del__(self) :
    sys.stdout.write("Deleting Spam:%s\n" % self.name)
    sys.stdout.flush()

def cleaner(reference) :
  sys.stdout.write("In callback with reference %s\n" % reference)
  sys.stdout.flush()

spam = Spam("first")
wk_spam = weakref.ref(spam, cleaner)
del spam

Я получаю вывод 

$ python weakref_test.py 
In callback with reference <weakref at 0xc760a8; dead>
Deleting Spam:first

Есть ли какой-нибудь другой обычный способ сделать то, что я хочу? Могу ли я каким-то образом вызвать завершение в моем обратном вызове?

Ответы [ 2 ]

3 голосов
/ 04 августа 2009

Если «делать то, что вы хотите» означает «запускать код, когда ресурс покидает контекст» (вместо, например, «злоупотреблять сборщиком мусора, чтобы делать что-то»), вы смотрите в неправильном направлении. Python абстрагировал эту идею как context-manager , используемый с оператором with. 

from __future__ import with_statement
import sys
class Spam(object):
    def __init__(self, name):
        self.name = name

    def __enter__(self):
        sys.stdout.write("Entering Spam:%s\n" % self.name)
        sys.stdout.flush()

    def __exit__(self, type, value, traceback):
        sys.stdout.write("Lets clean up Spam:%s\n" % self.name) 
        if type is None:
            sys.stdout.write("Leaving Spam:%s in peace\n" % self.name)
            return
        else:
            sys.stdout.write("Leaving Spam:%s with Exception:%r\n" % (self.name, value))


with Spam("first") as spam:
    pass

with Spam("2nd") as spam:
    raise Exception("Oh No!")

дает: 

Entering Spam:first
Lets clean up Spam:first
Leaving Spam:first in peace
Entering Spam:2nd
Lets clean up Spam:2nd
Leaving Spam:2nd with Exception:Exception('Oh No!',)
Traceback (most recent call last):
  File "asd.py", line 24, in <module>
    raise Exception("Oh No!")
Exception: Oh No!
0 голосов
/ 04 августа 2009

Вот решение, которое использует сериализованный цикл мусора в другом потоке. Это, вероятно, самое близкое решение, которое вы получите. 

import sys
from threading import Thread
from Queue import Queue
import weakref

alive = weakref.WeakValueDictionary()
dump = Queue()

def garbageloop():
    while True:
        f = dump.get()
        f()

garbage_thread = Thread(target=garbageloop)
garbage_thread.daemon = True
garbage_thread.start()

class Spam(object) :
  def __init__(self, name) :
    self.name = name
    alive[id(self)] = self

  def __del__(self) :
    sys.stdout.write("Deleting Spam:%s\n" % self.name)
    sys.stdout.flush()
    dump.put(lambda:cleaner(id(self)))

def cleaner(address):
  if address in alive:
    sys.stdout.write("Object was still alive\n")
  else:
    sys.stdout.write("Object is dead\n")
  sys.stdout.flush()

spam = Spam("first")
del spam
...