(self)
| 96 | self._timers = TimerManager() |
| 97 | |
| 98 | def maybe_start(self): |
| 99 | with self._lock: |
| 100 | if not reactor.running: |
| 101 | self._thread = Thread(target=reactor.run, |
| 102 | name="cassandra_driver_twisted_event_loop", |
| 103 | kwargs={'installSignalHandlers': False}) |
| 104 | self._thread.daemon = True |
| 105 | self._thread.start() |
| 106 | atexit.register(partial(_cleanup, weakref.ref(self))) |
| 107 | |
| 108 | def _reactor_stopped(self): |
| 109 | return reactor._stopped |