summaryrefslogtreecommitdiffstats
path: root/Lib/multiprocessing
diff options
context:
space:
mode:
authorSandro Tosi <sandro.tosi@gmail.com>2012-02-15 22:27:00 (GMT)
committerSandro Tosi <sandro.tosi@gmail.com>2012-02-15 22:27:00 (GMT)
commitcd77815e4ca1339422763b2ec47351d545409287 (patch)
tree59c06b3c73574807624b086e368343aa82bfe48b /Lib/multiprocessing
parent91a874196096c9842144804861a4b1593d730315 (diff)
parent5cb522cb32541c5c98df5d4571fef0ecf988cbaa (diff)
downloadcpython-cd77815e4ca1339422763b2ec47351d545409287.zip
cpython-cd77815e4ca1339422763b2ec47351d545409287.tar.gz
cpython-cd77815e4ca1339422763b2ec47351d545409287.tar.bz2
Issue #11836: document and expose multiprocessing.SimpleQueue
Diffstat (limited to 'Lib/multiprocessing')
-rw-r--r--Lib/multiprocessing/__init__.py9
1 files changed, 8 insertions, 1 deletions
diff --git a/Lib/multiprocessing/__init__.py b/Lib/multiprocessing/__init__.py
index e6e16c8..e012440 100644
--- a/Lib/multiprocessing/__init__.py
+++ b/Lib/multiprocessing/__init__.py
@@ -48,7 +48,7 @@ __all__ = [
'Manager', 'Pipe', 'cpu_count', 'log_to_stderr', 'get_logger',
'allow_connection_pickling', 'BufferTooShort', 'TimeoutError',
'Lock', 'RLock', 'Semaphore', 'BoundedSemaphore', 'Condition',
- 'Event', 'Queue', 'JoinableQueue', 'Pool', 'Value', 'Array',
+ 'Event', 'Queue', 'SimpleQueue', 'JoinableQueue', 'Pool', 'Value', 'Array',
'RawValue', 'RawArray', 'SUBDEBUG', 'SUBWARNING',
]
@@ -223,6 +223,13 @@ def JoinableQueue(maxsize=0):
from multiprocessing.queues import JoinableQueue
return JoinableQueue(maxsize)
+def SimpleQueue():
+ '''
+ Returns a queue object
+ '''
+ from multiprocessing.queues import SimpleQueue
+ return SimpleQueue()
+
def Pool(processes=None, initializer=None, initargs=(), maxtasksperchild=None):
'''
Returns a process pool object