Giriş ve Temel Kavramlar
Python'da eş zamanlı (concurrent) işlemler gerçekleştirirken, özellikle I/O işlemleri veya zaman alan görevlerde, bloklamayı önlemek için asyncio kütüphanesi ve onun sağladığı yapılar oldukça kritik hale gelir. Bu yapıların başında gelenlerden biri de
asyncio.Queue nesnesidir. Bu kuyruk, üretici-tüketici modelini kolayca uygulamayı sağlar ve özellikle yüksek performanslı, asenkron tabanlı uygulamalarda iş akışını düzenlemek için vazgeçilmezdir.
Async Queue'nun Kurulumu ve Kullanımı
İlk adım olarak, asyncio kütüphanesini projeye dahil etmek gerekir. Python 3.4 ve üzeri sürümler doğal olarak
asyncio desteğiyle gelir.
Kurulum gerektirmez, çünkü standart kütüphanedir.
Bir
asyncio.Queue nesnesi oluştururken, kapasite sınırını belirleyebilirsiniz.
Örneğin, maksimum 10 öğe tutacak bir kuyruk şöyle tanımlanır:
1queue = asyncio.Queue(maxsize=10)
Kuyruğa öğe ekleme ve çıkarma işlemleri asenkron fonksiyonlar içinde yapılır:
- put metodu, kuyrukta boş alan varsa öğeyi ekler, değilse bekler.
- get metodu, kuyruktan öğe çıkarır ve kuyruk boşsa bekler.
Örnek kullanım:
12345678910111213141516async def producer(queue):
for i in range(20):
await queue.put(i)
print(f'Ürün eklendi: {i}')
async def consumer(queue):
while True:
item = await queue.get()
print(f'Ürün alındı: {item}')
queue.task_done()
async def main():
q = asyncio.Queue(maxsize=5)
await asyncio.gather(producer(q), consumer(q))
asyncio.run(main())
Burada producer, sırayla öğeleri kuyruğa eklerken, consumer ise sürekli kuyruğu dinleyip öğeleri tüketir. Bu yapı, yüksek trafikli uygulamalarda işlevselliği artırırken, kaynak yönetimini de optimize eder.
Performans ve Dikkat Edilmesi Gerekenler
- task_done() çağrısı, tüketilen öğenin işlendiğini belirtmek için önemlidir.
- join() metodu, tüm öğelerin işlendiğinden emin olmak için kullanılabilir.
- Kuyruk kapasitesini iyi ayarlamak, hem bellek kullanımı hem de performans açısından kritiktir.
- Çok sayıda üretici ve tüketici varsa, deadlock veya starvation gibi sorunlara dikkat edilmeli.
Python async queue, asenkron programlama paradigmalarının temel taşlarından biri olup, doğru yapılandırıldığında yüksek verimli, ölçeklenebilir uygulamalar geliştirmeye imkan tanır.
