import sys
import threading
import warnings
-import _multiprocessing
-import _posixshmem
from . import spawn
from . import util
_CLEANUP_FUNCS = {
'noop': lambda: None,
- 'semaphore': _multiprocessing.sem_unlink,
- 'shared_memory': _posixshmem.shm_unlink
}
+if os.name == 'posix':
+ import _multiprocessing
+ import _posixshmem
+
+ _CLEANUP_FUNCS.update({
+ 'semaphore': _multiprocessing.sem_unlink,
+ 'shared_memory': _posixshmem.shm_unlink,
+ })
+
class ResourceTracker(object):