Add multiprocessing's SimpleQueue to those fixed by future

Author: fergofrog

src/future/moves/multiprocessing.py

@@ -0,0 +1,7 @@
+from __future__ import absolute_import
+from future.utils import PY3
+
+from multiprocessing import *
+if not PY3:
+    __future_module__ = True
+    from multiprocessing.queues import SimpleQueue

src/future/standard_library/__init__.py

@@ -34,6 +34,7 @@
     from collections import OrderedDict, Counter     # even on Py2.6
     from subprocess import getoutput, getstatusoutput
     from subprocess import check_output              # even on Py2.6
+    from multiprocessing import SimpleQueue
 
 (The renamed modules and functions are still available under their old
 names on Python 2.)
@@ -109,6 +110,7 @@
            'future.moves.socketserver': 'socketserver',
            'ConfigParser': 'configparser',
            'repr': 'reprlib',
+           'multiprocessing.queues': 'multiprocessing',
            # 'FileDialog': 'tkinter.filedialog',
            # 'tkFileDialog': 'tkinter.filedialog',
            # 'SimpleDialog': 'tkinter.simpledialog',
@@ -184,6 +186,7 @@
          ('itertools', 'filterfalse','itertools', 'ifilterfalse'),
          ('itertools', 'zip_longest','itertools', 'izip_longest'),
          ('sys', 'intern','__builtin__', 'intern'),
+         ('multiprocessing', 'SimpleQueue', 'multiprocessing.queues', 'SimpleQueue'),
          # The re module has no ASCII flag in Py2, but this is the default.
          # Set re.ASCII to a zero constant. stat.ST_MODE just happens to be one
          # (and it exists on Py2.6+).

src/libpasteurize/fixes/fix_imports.py

@@ -16,6 +16,7 @@
            u"winreg": u"_winreg",
            u"configparser": u"ConfigParser",
            u"copyreg": u"copy_reg",
+           u"multiprocessing.SimpleQueue": u"multiprocessing.queues.SimpleQueue",
            u"queue": u"Queue",
            u"socketserver": u"SocketServer",
            u"_markupbase": u"markupbase",

tests/test_future/test_standard_library.py

@@ -295,6 +295,15 @@ def test_bytesio(self):
         for method in ['tell', 'read', 'seek', 'close', 'flush', 'getvalue']:
             self.assertTrue(hasattr(s, method))
 
+    def test_SimpleQueue(self):
+        from multiprocessing import SimpleQueue
+        sq = SimpleQueue()
+        self.assertTrue(sq.empty())
+        sq.put('thing')
+        self.assertFalse(sq.empty())
+        self.assertEqual(sq.get(), 'thing')
+        self.assertTrue(sq.empty())
+
     def test_queue(self):
         import queue
         q = queue.Queue()