Initialize the ThreadSafeQueue with an empty queue and a lock for thread safety. Parameters: - None Returns: - None
(self)
| 85 | |
| 86 | class ThreadSafeQueue: |
| 87 | def __init__(self): |
| 88 | """ |
| 89 | Initialize the ThreadSafeQueue with an empty queue and a lock for thread safety. |
| 90 | |
| 91 | Parameters: |
| 92 | - None |
| 93 | |
| 94 | Returns: |
| 95 | - None |
| 96 | """ |
| 97 | self._queue = queue.Queue() |
| 98 | self._lock = threading.Lock() |
| 99 | |
| 100 | def put(self, item): |
| 101 | """ |
nothing calls this directly
no outgoing calls
no test coverage detected