"TypeError: cannot pickle '_thread.lock' object" when running simple ProcessSubscriptionProducer on Windows #36
Description
Implemented the following class:
import time
import logging
import asyncio
from rtcbot.base import ProcessSubscriptionProducer
class TestProcessProducer(ProcessSubscriptionProducer):
_log = logging.getLogger("bot.TestProcessProducer")
def __init__(self, loop=None):
super().__init__(asyncio.Queue, logger=self._log, loop=loop)
def _producer(self):
"""
Runs the actual frame capturing code.
"""
self._log.info("Started TestProcessProducer")
self._setReady(True)
while not self._shouldClose:
print("PROCESS")
self._put_nowait("PROCESS")
time.sleep(1)
self._setReady(False)
self._log.info("Ended TestProcessProducer")which, when instantiating (prod = TestProcessProducer()), produces the following error:
Traceback (most recent call last):
File "main.py", line 111, in main
prod = TestProcessProducer()
File "test_process_producer.py", line 17, in __init__
super().__init__(asyncio.Queue, logger=self._log, loop=loop)
File "site-packages\rtcbot\base\multiprocess.py", line 51, in __init__
self._producerProcess.start()
File "multiprocessing\process.py", line 121, in start
self._popen = self._Popen(self)
File "context.py", line 224, in _Popen
return _default_context.get_context().Process._Popen(process_obj)
File "context.py", line 327, in _Popen
return Popen(process_obj)
File "popen_spawn_win32.py", line 93, in __init__
reduction.dump(process_obj, to_child)
File "reduction.py", line 60, in dump
ForkingPickler(file, protocol).dump(obj)
TypeError: cannot pickle '_thread.lock' objectIs it because I am trying to run this on Windows and Python 3.8? Any way to work around it?
Found this ticket where it seems like this is not an issue on Linux only: Koed00/django-q#424