(cls)
| 115 | |
| 116 | @classmethod |
| 117 | def create_mp_lock(cls): |
| 118 | if not hasattr(cls, 'mp_lock'): |
| 119 | try: |
| 120 | from multiprocessing import RLock |
| 121 | cls.mp_lock = RLock() |
| 122 | except (ImportError, OSError): # pragma: no cover |
| 123 | cls.mp_lock = None |
| 124 | |
| 125 | @classmethod |
| 126 | def create_th_lock(cls): |