Skip to content

Commit 938c8a7

Browse files
committed
make PeriodicExecutor sync only
1 parent 56b37c2 commit 938c8a7

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

pymongo/periodic_executor.py

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,7 @@ def __init__(
152152
self._name = name
153153
self._skip_sleep = False
154154
self._thread_will_exit = False
155-
self._lock = _ALock(_create_lock())
155+
self._lock = _create_lock()
156156

157157
def __repr__(self) -> str:
158158
return f"<{self.__class__.__name__}(name={self._name}) object at 0x{id(self):x}>"
@@ -224,21 +224,21 @@ def update_interval(self, new_interval: int) -> None:
224224
def skip_sleep(self) -> None:
225225
self._skip_sleep = True
226226

227-
async def _should_stop(self) -> bool:
228-
async with self._lock:
227+
def _should_stop(self) -> bool:
228+
with self._lock:
229229
if self._stopped:
230230
self._thread_will_exit = True
231231
return True
232232
return False
233233

234-
async def _run(self) -> None:
235-
while not await self._should_stop():
234+
def _run(self) -> None:
235+
while not self._should_stop():
236236
try:
237-
if not await self._target():
237+
if not self._target():
238238
self._stopped = True
239239
break
240240
except BaseException:
241-
async with self._lock:
241+
with self._lock:
242242
self._stopped = True
243243
self._thread_will_exit = True
244244

@@ -249,7 +249,7 @@ async def _run(self) -> None:
249249
else:
250250
deadline = time.monotonic() + self._interval
251251
while not self._stopped and time.monotonic() < deadline:
252-
await asyncio.sleep(self._min_interval)
252+
time.sleep(self._min_interval)
253253
if self._event:
254254
break # Early wake.
255255

0 commit comments

Comments
 (0)