Простой код с использованием последовательного порта в многопроцессорной среде не работает

#python #multiprocessing #serial-port

Вопрос:

Я пытаюсь написать многопроцессорный скрипт python в Windows, который будет считывать последовательный порт rs232 в одном процессе и отправлять данные обратно в основной процесс.

Я сузил свою проблему до создания соединения с последовательным портом (в основном процессе) и использования доступа к нему (в другом процессе). Скрипт состоит из двух файлов. Первый файл ( test-main.py ) является основным процессом, второй файл ( test-class.py ) содержит класс последовательного порта.

test-main.py

 from multiprocessing import Process, Queue
import serial
from test_class import test

def main():

    #RS232 Parameteres to open serial connection
    test_serial = serial.Serial(
        port ='COM9',
        baudrate=9600,
        parity=serial.PARITY_NONE,
        stopbits=serial.STOPBITS_ONE,
        bytesize=serial.EIGHTBITS,
        timeout=0.1)

    #create instance of test class
    test_instance=test()

    #creat a new thread which will measure speed and initiate relay
    test_instance = Process(target=test_instance.test_method, args=(test_serial,))
    test_instance.daemon = True
    test_instance.start()

        
if __name__ == '__main__':
    main() 
 

test-class.py

 from multiprocessing import Process, Queue
import serial

class test:

    def test_method (self,rs232_connection):
        #main loop
        while 1==1:
            print(rs232_connection)
 

Ошибка, которую я получаю, такова:

 *C:UsersUserDocumentsBatterUpPython>py test-main.py
Traceback (most recent call last):
  File "test-main.py", line 26, in <module>
    main()
  File "test-main.py", line 22, in main
    test_instance.start()
  File "C:UsersUserAppDataLocalProgramsPythonPython37-32libmultiprocessingprocess.py", line 112, in start
    self._popen = self._Popen(self)
  File "C:UsersUserAppDataLocalProgramsPythonPython37-32libmultiprocessingcontext.py", line 223, in _Popen
    return _default_context.get_context().Process._Popen(process_obj)
  File "C:UsersUserAppDataLocalProgramsPythonPython37-32libmultiprocessingcontext.py", line 322, in _Popen
    return Popen(process_obj)
  File "C:UsersUserAppDataLocalProgramsPythonPython37-32libmultiprocessingpopen_spawn_win32.py", line 89, in __init__
    reduction.dump(process_obj, to_child)
  File "C:UsersUserAppDataLocalProgramsPythonPython37-32libmultiprocessingreduction.py", line 60, in dump
    ForkingPickler(file, protocol).dump(obj)
ValueError: ctypes objects containing pointers cannot be pickled
C:UsersUserDocumentsBatterUpPython>Traceback (most recent call last):
  File "<string>", line 1, in <module>
  File "C:UsersUserAppDataLocalProgramsPythonPython37-32libmultiprocessingspawn.py", line 99, in spawn_main
    new_handle = reduction.steal_handle(parent_pid, pipe_handle)
  File "C:UsersUserAppDataLocalProgramsPythonPython37-32libmultiprocessingreduction.py", line 87, in steal_handle
    _winapi.DUPLICATE_SAME_ACCESS | _winapi.DUPLICATE_CLOSE_SOURCE)
PermissionError: [WinError 5] Access is denied*
 

Комментарии:

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

2. Глобальная память, разделяемая между процессами, отсутствует. Даже если вы смогли передать serial.Serial экземпляр другому процессу в качестве аргумента, весьма вероятно, что он не поддерживает многопроцессорную обработку. Было бы лучше всего выполнить весь доступ к последовательному порту в другом процессе и просто отправить результаты обратно в основной процесс.

3. Спасибо! Проблема решена. Я включил всю инициализацию последовательного порта в метод test_method, и он работает.