Cannot achieve concurrency with paddleocr

[Ali-Raza12]

I am trying to run paddle ocr asynchronously but I am not able to achieve it as you can see my approach in the code snippet attached below. I want to do ocr for each frame in background and it should not block any execution of the main function. I am not adept with asynchronous programming and this is what I implemented to the best of my knowledge. Any help would be much appreciated.

import asyncio
import cv2
from paddleocr import PaddleOCR

paddle_ocr = PaddleOCR(use_gpu=True)
def ocr(image):
    return paddle_ocr.ocr(image)

async def perform_ocr(queue):
    loop = asyncio.get_running_loop()
    while True:
        image = await queue.get()
        text = await loop.run_in_executor(None, ocr, image)
        print("Text from image:", text)
        queue.task_done()

async def main():
    cap = cv2.VideoCapture("video.mp4")
    queue = asyncio.Queue()
    consumer_task = asyncio.create_task(perform_ocr(queue))

    while True:
        _, image = cap.read() 
        await queue.put(image)

        cv2.imshow("Output", image)
        cv2.waitKey(1)
        await asyncio.sleep(0) 

asyncio.run(main())