GithubFollow/One-KVM
1
0
Fork 0
mirror of https://github.com/mofeng-git/One-KVM.git synced 2025-12-12 09:10:30 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

put_nowait

Browse Source
This commit is contained in:
Devaev Maxim 2020-03-04 00:26:45 +03:00
parent 552bb93212
commit 52e117df3c
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
kvmd/aiomulti.py
View File

@ -36,7 +36,7 @@ class AioProcessNotifier:
self.__queue: multiprocessing.queues.Queue = multiprocessing.Queue() self.__queue: multiprocessing.queues.Queue = multiprocessing.Queue()
def notify(self) -> None: def notify(self) -> None:
self.__queue.put(None) self.__queue.put_nowait(None)
async def wait(self) -> None: async def wait(self) -> None:
while not (await aiotools.run_async(self.__inner_wait)): while not (await aiotools.run_async(self.__inner_wait)):

2
kvmd/plugins/hid/otg/device.py
View File

@ -124,7 +124,7 @@ class BaseDeviceProcess(multiprocessing.Process): # pylint: disable=too-many-in
self.join() self.join()
def _queue_event(self, event: BaseEvent) -> None: def _queue_event(self, event: BaseEvent) -> None:
self.__events_queue.put(event) self.__events_queue.put_nowait(event)
def _ensure_write(self, report: bytes, reopen: bool=False, close: bool=False) -> bool: def _ensure_write(self, report: bytes, reopen: bool=False, close: bool=False) -> bool:
if reopen: if reopen: