future

6Ciepło

1Odpowiedz

Czekać na którąkolwiek z danych kontraktów futures w Scali?

Załóżmy, że muszę wykonać kilka równoległych zadań w Scali. Każde zadanie wykonuje blokowanie (np. Process.waitFor). Teraz chciałbym poczekać, aż zakończy się jedno z zadań. Jak rozumiem, powinienem u

9Ciepło

2Odpowiedz

Futures do blokowania połączeń w Scala

Akka dokumentacja mówi: możesz ulec pokusie, aby po prostu zawinąć blokowania połączeń wewnątrz przyszłość i pracować z tym, że zamiast, ale ta strategia jest zbyt prosta: jesteś całkiem prawdopodobne

10Ciepło

4Odpowiedz

Jak utworzyć funkcję obejmującą rekurencję tail futures?

W mojej aplikacji Scala, mam funkcję, która wywołuje funkcję, która zwraca wynik typu Future [T]. Muszę przekazać zmapowany wynik w rekurencyjnym wywołaniu funkcji. Chcę, aby to było rekurencyjne, ale

6Ciepło

1Odpowiedz

Wyjątki Akka Futures Wyjątki

Co dzieje się, gdy aktor przyszłości rzuca wyjątek? Zgodnie z dokumentacją Akka w http://doc.akka.io/docs/akka/snapshot/scala/futures.html: to nie ma znaczenia, jeśli aktor lub dyspozytor jest ukończe

7Ciepło

3Odpowiedz

Kiedy Futures mogą być bardziej odpowiednie niż Aktorzy (lub odwrotnie) w Scali?

Załóżmy, że muszę wykonać kilka równoczesnych zadań. Mogę zawijać każde zadanie w Future i czekać na ich zakończenie. Alternatywnie mogę utworzyć Actor dla każdego zadania. Każdy Actor wykona swoje za

8Ciepło

1Odpowiedz

std :: asynchronicznie zanikające (tracące) wartości rvalue w Visual Studio 2012 Update 2. Jakiekolwiek obejścia?

Rozważmy poniższy kod: #include <memory> #include <future> using namespace std; template <typename T, typename Work> void Test2(future<T> f, Work w) { async([](future<T> && f, Work w)

40Ciepło

3Odpowiedz

robi Future Timeout zabić wykonanie wątku

Przy zastosowaniu ExecutorService i Future obiektów (przy składaniu Runnable zadania), jeśli mogę określić wartość limitu czasu dla funkcji uzyskać Future, czy podstawowa wątek zginąć gdy TimeoutExcep

15Ciepło

3Odpowiedz

Python `concurrent.futures`: Iterowanie na futures zgodnie z kolejnością wypełniania

Chcę czegoś podobnego do executor.map, z wyjątkiem sytuacji, gdy sprawdzam wyniki, chcę je powtórzyć zgodnie z kolejnością wypełniania, np. element pracy, który został ukończony jako pierwszy, powinie

13Ciepło

2Odpowiedz

Scala - futures i współbieżności

Próbuję zrozumieć futures Scala pochodzących z Java tle: Rozumiem, można napisać: val f = Future { ... } to mam dwa pytania: Jak to przyszłość zaplanowane ? Automatycznie? Jakiego programu planujące

6Ciepło

1Odpowiedz

Metody gotowe i wynik Future w Scali nie mogą być wywołane bezpośrednio

Zauważyłem, że metody ready i result z scala.concurrent.Future nie mogą być wywołane bezpośrednio. Kiedy wywołuję je w REPL, pojawia się błąd. Dlatego muszę zadzwonić pod numer Await.ready i Await.res