()
| 1619 | lock = _threading.Lock() |
| 1620 | |
| 1621 | def worker() -> None: |
| 1622 | barrier.wait() |
| 1623 | tok = cache.get_token() |
| 1624 | with lock: |
| 1625 | results.append(tok) |
| 1626 | |
| 1627 | threads = [_threading.Thread(target=worker) for _ in range(8)] |
| 1628 | for t in threads: |
no test coverage detected