Class PyDBCommandThread

pydevd.py:258–295

# PyDBCommandThread
# =======================================================================================================================
class PyDBCommandThread(PyDBDaemonThread):
    def __init__(self, py_db):
        PyDBDaemonThread.__init__(self, py_db)
        self._py_db_command_thread_event = py_db._py_db_command_thread_event
        self.name = "pydevd.CommandThread"

    @overrides(PyDBDaemonThread._on_run)
    def _on_run(self):
        # Delay a bit this initialization to wait for the main program to start.
        self._py_db_command_thread_event.wait(TIMEOUT_SLOW)

        if self._kill_received:
            return

        try:
            while not self._kill_received:
                try:
                    self.py_db.process_internal_commands(("*",))
                except:
                    pydev_log.info("Finishing debug communication...(2)")
                self._py_db_command_thread_event.clear()
                self._py_db_command_thread_event.wait(TIMEOUT_SLOW)
        except:
            try:
                pydev_log.debug(sys.exc_info()[0])
            except:
                # In interpreter shutdown many things can go wrong (any module variables may
                # be None, streams can be closed, etc).
                pass

            # only got this error in interpreter shutdown
            # pydev_log.info('Finishing debug communication...(3)')

    @overrides(PyDBDaemonThread.do_kill_pydev_thread)
    def do_kill_pydev_thread(self):
        PyDBDaemonThread.do_kill_pydev_thread(self)
        # Set flag so that it can exit before the usual timeout.
        self._py_db_command_thread_event.set()


# =======================================================================================================================