Intelligent distribution of tasks among workers in Celery

After a week of trying and searching, I didn't get any results and I would appreciate your help.

Summary:<br>
I have 4 workers and there is an app.task inside each worker.<br>
Every day, these 4 workers have to do nearly thousand tasks.<br>
The problem is how to intelligently divide tasks among these 4 workers.<br>
<br>
more details:<br>
My current code divides 1,000 tasks by 4, and then each worker is given 250 tasks. Why do I share? Because I have to apply_async the tasks at the beginning of the work. (so each worker has a separate queue)<br>
Workers execute tasks without any problems, but a challenge arises when some workers execute tasks faster and end up without tasks, while some workers may be executing their tasks for more hours.
<br><br>
<br>
What am I looking for?<br>
We are looking for a way to have all 1,000 tasks in one queue without dividing them and automatically remove these 4 worker tasks from this 1,000 queue and execute them, in this case the other workers will finish their tasks almost together.

<br>
My codes are in 4 files:
<br>

celery.py:

from __future__ import absolute_import,unicode_literals
from celery import Celery


app=Celery('celery_app')
app.config_from_object('celery_app.celeryconfig')

if __name__ == '__main__':
    app.start()

celeryconfig.py:

broker_url='amqp://guest@localhost//'
result_backend='rpc://'
include=['celery_app.tasks']
worker_prefetch_multiplier = 1

task_routes={
    'celery_app.tasks.app_1000':{'queue':'q_1000'},
    'celery_app.tasks.app_1000':{'queue':'q_1002'},
    'celery_app.tasks.app_1000':{'queue':'q_1004'},
    'celery_app.tasks.app_1000':{'queue':'q_1006'},
    'celery_app.tasks.app_timeout':{'queue':'q_timeout'},
}

tasks.py:<br>
There are many codes in the tasks.py file, see this link in GitHub.

api.py:<br>
This is a simulated api, for example, if I send the number 1000, it is like it has to do 1000 tasks and this thousand tasks are divided between 4 apps.<br>

from fastapi import FastAPI, HTTPException,Request
from celery_app.tasks import app_1000,app_1002,app_1004,app_1006,get_active_queue
import random

app = FastAPI()


@app.get("/run_tasks")
async def run_tasks(num_of_tasks:int):
    try: 
        app_list = [app_1000,app_1002,app_1004,app_1006]

        for i in range(0,num_of_tasks, 4):
            app_list[0].apply_async() 
            app_list[1].apply_async()     
            app_list[2].apply_async()     
            app_list[3].apply_async()     
    
        
        return 'ok'

    except Exception as e:
        raise HTTPException(status_code=500, detail=str(e))
    

@app.get("/get_active_queue")
async def get_active_q():
    res = get_active_queue()
    print(res)
    return 'ok'

<br>
Please guide me how to do this?
If something was dumb, comment so I can explain more.

<br>
My code is in the following link: https://github.com/arezooebrahimi/celery_distribution_tasks

If I understand it correctly, you want your workers to pick up tasks as soon as they are free and all the workers have same tasks. Using a single queue, with all the workers listening on it should work and this is how it is used by default. If you are having long running tasks, you might want to set worker_prefetch_multiplier=1 in the celery configuration. I don't understand what made you start with 10 different queues instead of a single queue for all the workers.