{"type":"doc","content":[{"type":"paragraph","content":[{"type":"text","text":"Paralel programlamada en sık yapılan hata, standart "},{"type":"text","marks":[{"type":"code"}],"text":"List"},{"type":"text","text":" veya "},{"type":"text","marks":[{"type":"code"}],"text":"Dictionary"},{"type":"text","text":" koleksiyonlarını birden fazla thread ile aynı anda manipüle etmeye çalışmaktır. Sonuç? Ya "},{"type":"text","marks":[{"type":"code"}],"text":"IndexOutOfRangeException"},{"type":"text","text":" ya da verinin sessizce kaybolması."}]},{"type":"paragraph","content":[{"type":"text","text":"Senior bir geliştirici, tekerleği yeniden icat etmek (yani her yere "},{"type":"text","marks":[{"type":"code"}],"text":"lock"},{"type":"text","text":" koymak) yerine, bu iş için optimize edilmiş "},{"type":"text","marks":[{"type":"bold"}],"text":"Concurrent Collections"},{"type":"text","text":" yapılarını kullanır."}]},{"type":"heading","attrs":{"level":3},"content":[{"type":"text","text":"1. Neden Standart Koleksiyonlar Yetmiyor?"}]},{"type":"paragraph","content":[{"type":"text","text":"Standart bir "},{"type":"text","marks":[{"type":"code"}],"text":"List"},{"type":"text","text":" üzerine paralel ekleme yaptığınızda, koleksiyonun iç kapasitesi (internal array) dolup yeniden boyutlandırılmaya (resize) çalışıldığında iki thread birbirinin üzerine yazar."}]},{"type":"codeBlock","attrs":{"language":null},"content":[{"type":"text","text":"// TEHLİKELİ KOD: Bu liste muhtemelen bozulacak veya eksik veri tutacak.\r\nvar list = new List();\r\nParallel.For(0, 1000, i => list.Add(i));"}]},{"type":"heading","attrs":{"level":3},"content":[{"type":"text","text":"2. ConcurrentDictionary: Performans Canavarı"}]},{"type":"paragraph","content":[{"type":"text","text":"Eğer çok thread'li bir ortamda cache veya sözlük yapısı yönetiyorsanız, "},{"type":"text","marks":[{"type":"code"}],"text":"ConcurrentDictionary"},{"type":"text","text":" hayat kurtarır. En büyük avantajı, tüm koleksiyonu kilitlemek yerine "},{"type":"text","marks":[{"type":"bold"}],"text":"Fine-grained locking"},{"type":"text","text":" (parçalı kilitleme) kullanarak sadece ilgili \"bucket\"ı kilitlemesidir."}]},{"type":"codeBlock","attrs":{"language":null},"content":[{"type":"text","text":"var cache = new ConcurrentDictionary();\r\n\r\n// Ekleme veya Güncelleme (Atomic)\r\n// Eğer anahtar yoksa ekler, varsa mevcut değeri günceller.\r\ncache.AddOrUpdate(1, \"İlk Değer\", (key, oldVal) => \"Güncellenmiş Değer\");\r\n\r\n// Güvenli Okuma ve Ekleme\r\nstring value = cache.GetOrAdd(2, (key) => FetchFromDatabase(key));"}]},{"type":"heading","attrs":{"level":3},"content":[{"type":"text","text":"3. ConcurrentBag ve ConcurrentQueue: Hangisi Ne Zaman?"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"type":"text","marks":[{"type":"code"}],"text":"ConcurrentQueue"},{"type":"text","marks":[{"type":"bold"}],"text":":"},{"type":"text","text":" \"İlk giren ilk çıkar\" (FIFO) kuralı asenkron dünyada da bozulmasın istiyorsanız kullanılır. Özellikle Producer-Consumer desenleri için idealdir."}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"type":"text","marks":[{"type":"code"}],"text":"ConcurrentBag"},{"type":"text","marks":[{"type":"bold"}],"text":":"},{"type":"text","text":" Eğer elemanların sırası önemli değilse ve aynı thread hem ekleme hem okuma yapıyorsa (work-stealing senaryoları), "},{"type":"text","marks":[{"type":"code"}],"text":"ConcurrentBag"},{"type":"text","text":" en hızlısıdır."}]}]}]},{"type":"codeBlock","attrs":{"language":null},"content":[{"type":"text","text":"var orders = new ConcurrentQueue();\r\n\r\n// Producer (Üretici)\r\nParallel.For(0, 100, i => orders.Enqueue($\"Sipariş-{i}\"));\r\n\r\n// Consumer (Tüketici)\r\nwhile (orders.TryDequeue(out string order))\r\n{\r\n Console.WriteLine($\"İşleniyor: {order}\");\r\n}"}]},{"type":"heading","attrs":{"level":3},"content":[{"type":"text","text":"4. BlockingCollection: Gerçek Bir Orkestra Şefi"}]},{"type":"paragraph","content":[{"type":"text","text":"Bir Senior Developer'ın favori araçlarından biri "},{"type":"text","marks":[{"type":"code"}],"text":"BlockingCollection"},{"type":"text","text":"'dır. Bir kanal (channel) gibi davranır; eğer koleksiyon boşsa tüketiciyi bekletir, koleksiyon doluysa üreticiyi yavaşlatır."}]},{"type":"codeBlock","attrs":{"language":null},"content":[{"type":"text","text":"// Maksimum 10 eleman alabilen bir buffer\r\nvar buffer = new BlockingCollection(10);\r\n\r\n// Tüketici Thread\r\nTask.Run(() => {\r\n foreach (var item in buffer.GetConsumingEnumerable())\r\n {\r\n Console.WriteLine($\"Tüketiliyor: {item}\");\r\n }\r\n});\r\n\r\n// Üretici Thread\r\nfor (int i = 0; i < 50; i++)\r\n{\r\n buffer.Add(i); // Buffer doluysa burada otomatik bekler (Backpressure)\r\n}\r\nbuffer.CompleteAdding();"}]},{"type":"paragraph"}]}

Blog

Part 3: C# Thread Pool Mekanizması