I have a queue in which elements are received, and there are also 5 task executors, 3 for 30 elements and 2 for 50. How to make the task executors for 30 elements fill up first and deliver them to another queue (maximum 2 task executors in one direction), and only when there are no task executors for 30 elements did task executors for 50 elements start working