Futures tek bir iş parçacığında mı yürütülüyor? (Scala)

Question

Scala'daki varsayılan örtük yürütme bağlamını kullanarak, her yeni gelecek tek bir özel iş parçacığında hesaplanacak mı yoksa hesaplama bölüm havuzunda birden çok iş parçacığına bölünecek ve dağıtılacak mı?

Bunun işe yarayıp yaramadığını bilmiyorum, bu sorunun arka planı HtmlUnit API kullanarak birden çok eşzamanlı işlem gerçekleştirmek istiyorum. Bunu yapmak için her yeni WebClient örneğini bir Gelecekte kaydırırdım. Tek sorun, WebClient sınıfının iş parçacığı güvenli olmamasıdır, bu yüzden ayrıldığından ve farklı konulara gönderilebileceğinden endişeleniyorum.

Answer 1

Tek bir iş parçacığı üzerinde bir gelecek yürütülür. Birkaç iş parçacığında birkaç geleceği gerçekleştirilebilir. Yani, geleceğe daha fazla bir şey simültane olarak bir iş parçacığı işgal edebilir.

Nasıl çalışır? Bir Gelecek oluşturduğunuzda, bu, iş parçacığı havuzunuza görev gönderdiğiniz anlamına gelir - bu görev örtülü olarak paralelleştirilemez, dolayısıyla yalnızca bir iş parçacığında yürütülür. Havuza gönderilen bir veya daha fazla görev havuzun kuyruğuna yerleştirilir, bu nedenle yürütücü bu sıradan birer birer görevler alır ve her birini rastgele (veya kasıtlı olarak) seçilen iş parçacığı üzerinde çalıştırır. Bu yüzden birkaç Futures çeşitli konulara gidebilir.

Paylaşılan nesne hakkında - işlemler arasında paylaşılan nesne için güvenli bir şekilde işlem yapmanın tek yolu Executors.newFixedThreadPool(1) kullanıyor, tüm havuz için yalnızca bir iş parçacığı kullanacak. Başka bir çözüm - her gelecek için böyle bir nesneyi klonlamaktır. Oyuncular (paylaşılan nesneyi bir oyuncunun durumuna getir) en iyi seçenek olmalı.

Gelecekte bir nesne kullanırsanız - her şey iyi olmalıdır.

Not: Geleceğin işleyicisi, Future{ ... }.map(handler) gibi, geleceğin kendisinden farklı bir iş parçacığında gerçekleştirilebilir, ancak aslında bir sonuç elde etmek için başka bir Future oluşturur. flatMap için de geçerlidir. Daha doğrusu, eski Geleceğin başarıdan sonra (farklı bir iş parçacığı mümkün) işleyicisi başlatmak için CallbackRunnable oluşturur onComplete kullanmak - Bu geri arama sadece newely oluşturulan geleceği tamamlar, böylece yine "en fazla bir iş parçacığı gelecekte başına"

Answer 2

A Future[+T] garanti olamaz Birden fazla geleceğe sahip olması durumunda aynı konu üzerinde tamamlanacağını. Bu, aynı anda bir değişiklik istisnası veya bu çizgiler boyunca bir şey elde edeceğiniz anlamına gelmez. Sıralı olarak yürütmek için asenkron kod alabilirsiniz, bu durumda güvenli olacaktır.

İkinci sorunuz için, her bir gelecek için bir örneğiniz olduğu sürece, herhangi bir eşzamanlılık sorununuz olmamalıdır.