Message223869
| Author |
dan.oreilly |
| Recipients |
dan.oreilly, lee.clemens, sbt |
| Date |
2014年07月24日.18:49:24 |
| SpamBayes Score |
-1.0 |
| Marked as misclassified |
Yes |
| Message-id |
<1406227764.61.0.905896381722.issue21367@psf.upfronthosting.co.za> |
| In-reply-to |
| Content |
How are you importing JoinableQueue? You'll see this error if you import it from multiprocessing.queues instead of directly from multiprocessing. This is because multiprocessing.JoinableQueue is now a function:
def JoinableQueue(self, maxsize=0):
'''Returns a queue object'''
from .queues import JoinableQueue
return JoinableQueue(maxsize, ctx=self.get_context())
It provides the required context argument for you. Make sure your application is doing "from multiprocessing import JoinableQueue", rather than "from multiprocessing.queues import JoinableQueue". |
|
History
|
|---|
| Date |
User |
Action |
Args |
| 2014年07月24日 18:49:24 | dan.oreilly | set | recipients:
+ dan.oreilly, sbt, lee.clemens |
| 2014年07月24日 18:49:24 | dan.oreilly | set | messageid: <1406227764.61.0.905896381722.issue21367@psf.upfronthosting.co.za> |
| 2014年07月24日 18:49:24 | dan.oreilly | link | issue21367 messages |
| 2014年07月24日 18:49:24 | dan.oreilly | create |
|