queus 0.0.3

Python queue

📦 QUEUE

USAGE

Installation

pip install queus

Usage example

import asyncio
from Queue.functions import Queue
from Queue.functions import Queues

queue = Queue(workers=1)

async def runtask():
    print("Processing....")
    await asyncio.sleep(10)

async def main():
    tasks = ["Task01", "Task02"]
    for task in tasks:
        await queue.add(task)
    await queue.queue(task)
    await runtask()

"""
    await queue.remove(task)
           OR
    await Queue.remove(task)
"""
asyncio.run(main())