Must be called after a fork operation (will reset the ForkSafeLock).
()
| 497 | |
| 498 | |
| 499 | def after_fork(): |
| 500 | """ |
| 501 | Must be called after a fork operation (will reset the ForkSafeLock). |
| 502 | """ |
| 503 | global _fork_safe_locks |
| 504 | locks = _fork_safe_locks[:] |
| 505 | _fork_safe_locks = [] |
| 506 | for lock in locks: |
| 507 | lock = lock() |
| 508 | if lock is not None: |
| 509 | lock._init() |
| 510 | |
| 511 | |
| 512 | _thread_id_lock = ForkSafeLock() |