pyserial vs gsm-modem

В одном из проектов появилась необходимость настройки gsm-модема (mc52i) через последовательный порт: AT-команды, настройка параметров модема, запись и чтение смс, настройка профиля GPRS и т.п.

Само собой, будем использовать наш любимый Python, а работы с COM-портом существует отличная библиотека PySerial.

Завелось, как говорится, сполпинка, но при увеличении размера скрипта, когда обмен шел интенсивно, практически каждый раз при работе вылетало исключение writeTimeoutError.

В документации на pyserial про serial.write() написано следующее: Raises SerialTimeoutException: In case a write timeout is configured for the port and the time is exceeded.

Однако увеличение параметра writeTimeout на происходящее никак не повлияло. Кроме того, библиотека не предоставляет возможности настройки размера буфера порта. Возможно, причина исключения и не в буфере, но в чем, пока что мне непонятно.

Ок. Подсмотрел в примерах для pyserial, что используется запись и чтение в порт из отдельных потоков. Отлично. Создаем отдельный класс ThSerial.

class ThSerial:
    """ Serial port daemon class.
        """
    def __init__(self, port, baudrate, timeout = 1):
        try:
            self.serial = serial.Serial(port, baudrate)
        except serial.SerialException, e:
            sys.exit(1)
            
        self.in_data=[]
        self.out_data=[]
        self.timeout = timeout
        self.open()

    def open(self):
        self.alive = True
        self.receiver_thread = threading.Thread(target=self.reader)
        self.receiver_thread.setDaemon(1)
        self.receiver_thread.start()
        self.transmitter_thread = threading.Thread(target=self.writer)
        self.transmitter_thread.setDaemon(1)
        self.transmitter_thread.start()

где в методе open() создаем два потока для записи и чтения.

Приятная для таких новичков как я (хотя может быть и ограничивающая) особенность потоков в python - то, что все объекты автоматически безопасны, т.е. предусматривать средств распределения ресурсов для разных потоков в нашем случае не требуется.

Далее реализуем собственно демоны:

    def reader(self):
        while self.alive:
            data = self.serial.read(1)
            for character in data:
                self.in_data.append(character)
                
    def writer(self):
        while self.alive:
            if len(self.out_data) > 0:
                character = self.out_data.pop(0)
                self.serial.write(character)

И определяем для нашего классы методы write(), read() и readline(), как в классе serial, чтобы не переписывать уже имеющиеся скрипты.

Запуск. Всё отлично работает.

Странно, что подобный класс сразу не включили в библиотеку pyserial, хотя, может, это часть идеологии python :)

Исходный код можно взять здесь.

Конкретной причины, по которой происходит ошибка таймаут на запись, я так и не понял, далее искать стало лень :(

Update.

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