Реализуйте пакетный процесс с помощью производителя-потребителя

Я думаю, что TPL Dataflow был бы хорошим способом сделать это:

Для шага 2 вы должны использовать TransformBlock с MaxDegreeOfParallelism, установленным на 4, и BoundedCapacity, также установленным на 4, чтобы его очереди были пусты при работе. Он будет производить предметы в том же порядке, в котором они были получены, вам не нужно делать для этого ничего особенного. Для шага 3 используйте ActionBlock, а BoundedCapacity установите на свой предел. Затем свяжите их вместе и начните отправлять элементы в TransformBlock, в идеале используя что-то вроде await stepTwoBlock.SendAsync(…), чтобы асинхронно ожидать заполнения очереди.

В коде это будет выглядеть примерно так:

async Task ProcessData()
{
    var stepTwoBlock = new TransformBlock<OriginalText, ParsedText>(
        text => Parse(text),
        new ExecutionDataflowBlockOptions
        {
            MaxDegreeOfParallelism = 4,
            BoundedCapacity = 4
        });
    var stepThreeBlock = new ActionBlock<ParsedText>(
        text => LoadIntoDatabase(text),
        new ExecutionDataflowBlockOptions { BoundedCapacity = 10 });
    stepTwoBlock.LinkTo(
        stepThreeBlock, new DataflowLinkOptions { PropagateCompletion = true });

    // this is step one:
    foreach (var id in IdsToProcess)
    {
        OriginalText text = ReadText(id);
        await stepTwoBlock.SendAsync(text);
    }

    stepTwoBlock.Complete();
    await stepThreeBlock.Completion;
}