Mercurial > piecrust2
view piecrust/events.py @ 971:5485a11591ec
internal: Worker pool improvements
- Slightly more correct multi-processing code.
- Handle critical worker failures.
- Correctly setup workers when run from `py.test`.
- Add support for using `msgpack` or `marshall` instead of `pickle`.
author | Ludovic Chabant <ludovic@chabant.com> |
---|---|
date | Tue, 17 Oct 2017 01:00:55 -0700 |
parents | f070a4fc033c |
children |
line wrap: on
line source
class Event(object): """ A simple implementation of a subscribable event. """ def __init__(self): self._handlers = [] def __iadd__(self, handler): self._handlers.append(handler) return self def __isub__(self, handler): self._handlers.remove(handler) return self def fire(self, *args, **kwargs): # Make a copy of the handlers list in case some handler removes # itself while executing. handlers = list(self._handlers) for handler in handlers: handler(*args, **kwargs)