Это решается с помощью генератора. Можно с использованием пары генераторов.
первый - последовательный номер записи в очереди. он же пишется в запись очереди. второй - номер последней обработанной записи. просто обращаетест ко второму генереатору и получаете номер записи которую нужно обработать.
