Returns a queue object
(self, maxsize=0)
| 98 | return Barrier(parties, action, timeout, ctx=self.get_context()) |
| 99 | |
| 100 | def Queue(self, maxsize=0): |
| 101 | '''Returns a queue object''' |
| 102 | from .queues import Queue |
| 103 | return Queue(maxsize, ctx=self.get_context()) |
| 104 | |
| 105 | def JoinableQueue(self, maxsize=0): |
| 106 | '''Returns a queue object''' |