We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ccd578b commit 7236f20Copy full SHA for 7236f20
idom/core/layout.py
@@ -268,17 +268,18 @@ def __repr__(self) -> str:
268
269
class _ElementQueue:
270
271
- __slots__ = "_queue", "_pending"
+ __slots__ = "_loop", "_queue", "_pending"
272
273
def __init__(self) -> None:
274
+ self._loop = asyncio.get_event_loop()
275
self._queue: "asyncio.Queue[AbstractElement]" = asyncio.Queue()
276
self._pending: Set[int] = set()
277
278
def put(self, element: AbstractElement) -> None:
279
element_id = id(element)
280
if element_id not in self._pending:
281
self._pending.add(element_id)
- self._queue.put_nowait(element)
282
+ self._loop.call_soon_threadsafe(self._queue.put_nowait, element)
283
return None
284
285
async def get(self) -> AbstractElement:
0 commit comments