Added: parallel query work balancing based on actual processing queue length