Anda dapat mencapai ini menggunakan daftar Redis dengan antrean "pengiriman" tambahan yang BRPOP
semua pekerja untuk pekerjaan mereka. Setiap pekerjaan dalam antrian pengiriman diberi tag dengan ID antrian asli, dan ketika pekerja telah menyelesaikan pekerjaan itu pergi ke antrian asli ini dan melakukan RPOPLPUSH
ke antrian pengiriman untuk membuat pekerjaan berikutnya tersedia untuk pekerja lain. Oleh karena itu, antrian pengiriman akan memiliki maksimum num_queues elemen.
Satu hal yang harus Anda tangani adalah populasi awal antrian pengiriman saat antrian sumber kosong. Ini bisa saja berupa pemeriksaan yang dilakukan oleh penerbit terhadap tanda "kosong" untuk setiap antrian yang disetel pada awalnya, dan juga disetel oleh pekerja ketika tidak ada yang tersisa dalam antrian asli untuk dikirim. Jika tanda ini disetel, penerbit cukup LPUSH
pekerjaan pertama langsung ke antrian pengiriman.