Hello
Thanks for trying to help.
Reproducing:
It might be the platform or the Python version ?
I run Python 3.5 on Win 10 64-bit.
IDE is PyCharm (latest version)
join():
No difference if I call join() on it before exit(0). Still same error.
Calling shutdown() on the manager doesn't help either.
queue.Queue():
I thought I had to use the proxied queues to communicate between multiple processes safely.
I haven't be able to find any info on why there are three implementations of queues (multiprocessing.Queue, queue.Queue and Manager.Queue()).
I figured the use of proxied queue was best practice since it is usable over networks and between different interpreters on the same machine.
Cheers
queue.Queue():
queue.Queue() is not a drop-in replacement, I get a pickle error.
multiprocessing.Queue() is a drop-in replacement tho and can handle the message object I'm sending. It also doesn't give the weakref.py error message.
This solution works for this project but still doesn't help with future projects where I might need to rely on proxying queues over networks.
Thanks for trying to help.
Reproducing:
It might be the platform or the Python version ?
I run Python 3.5 on Win 10 64-bit.
IDE is PyCharm (latest version)
join():
No difference if I call join() on it before exit(0). Still same error.
Calling shutdown() on the manager doesn't help either.
queue.Queue():
I thought I had to use the proxied queues to communicate between multiple processes safely.
I haven't be able to find any info on why there are three implementations of queues (multiprocessing.Queue, queue.Queue and Manager.Queue()).
I figured the use of proxied queue was best practice since it is usable over networks and between different interpreters on the same machine.
Cheers
queue.Queue():
queue.Queue() is not a drop-in replacement, I get a pickle error.
multiprocessing.Queue() is a drop-in replacement tho and can handle the message object I'm sending. It also doesn't give the weakref.py error message.
This solution works for this project but still doesn't help with future projects where I might need to rely on proxying queues over networks.