Method put

gpustack/scheduler/queue.py:13–19

(self, item)

        self.lock = asyncio.Lock()

    async def put(self, item):
        async with self.lock:
            if item not in self.set:
                self.set.add(item)
                await self.queue.put(item)
            else:
                logger.debug(f"Item {item.__hash__()} already in queue.")

    async def get(self):
        item = await self.queue.get()