from multiprocessing.managers import ValueProxy
from multiprocessing.pool import ApplyResult
from multiprocessing.queues import SimpleQueue as MPSimpleQueue
+ from multiprocessing.queues import Queue as MPQueue
+ from multiprocessing.queues import JoinableQueue as MPJoinableQueue
except ImportError:
# _multiprocessing module is optional
ValueProxy = None
ApplyResult = None
MPSimpleQueue = None
+ MPQueue = None
+ MPJoinableQueue = None
try:
from multiprocessing.shared_memory import ShareableList
except ImportError:
if ctypes is not None:
generic_types.extend((ctypes.Array, ctypes.LibraryLoader))
if ValueProxy is not None:
- generic_types.extend((ValueProxy, ApplyResult, MPSimpleQueue))
+ generic_types.extend((ValueProxy, ApplyResult,
+ MPSimpleQueue, MPQueue, MPJoinableQueue))
def test_subscriptable(self):
for t in self.generic_types: