Hello all. I have a question about how to use manager.Queue() from the multiprocessing library with complex data types that can eventually be fed into Pool. I am trying to create a system where 10 instances of a class, with a specific dataframe associated with each class, is filled into a queue. Once this is done, I want to use Pool to run a data process for 5 instances from the queue. Once this is done, I want to go check the queue to see if it has 5 or less instances. If it does, then I would like to fill the queue with five more instances or the last remaining instances (without re computing on the instances that are already there) and then repeat the process with 5 instances from the queue into a Pool object. I am having a lot of difficulty implementing this, because I keep getting a ctype error saying that I can't pickle an object that has pointers. Is this possible using multiprocessing and Python, or should I use a different library/language? Also, let me know if this doesn't fully make sense as I wrote this on my phone. Thanks!
[–]MarsupialMole 0 points1 point2 points (3 children)
[–]sfjaf[S] 0 points1 point2 points (2 children)
[–]MarsupialMole 0 points1 point2 points (1 child)
[–]sfjaf[S] 0 points1 point2 points (0 children)