@@ -1821,8 +1821,8 @@ Running the following commands creates a server for a single shared queue which |
|
|
1821 |
1821 |
remote clients can access:: |
1822 |
1822 |
|
1823 |
1823 |
>>> from multiprocessing.managers import BaseManager |
1824 |
|
- >>> import queue |
1825 |
|
- >>> queue = queue.Queue() |
|
1824 |
+ >>> from queue import Queue |
|
1825 |
+ >>> queue = Queue() |
1826 |
1826 |
>>> class QueueManager(BaseManager): pass |
1827 |
1827 |
>>> QueueManager.register('get_queue', callable=lambda:queue) |
1828 |
1828 |
>>> m = QueueManager(address=('', 50000), authkey=b'abracadabra') |