#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, и он работает.