use task groups for concurrent queue consumers

use task groups for concurrent queue consumers #20203