Dlaczego nie ma słów kluczowych do synchronizacji / współbieżności? Jak dotąd moje badania dają mi jedno rozwiązanie - zawijasz kilka klas wysokiego poziomu i używasz ich do obsługi współbieżności. Biorąc pod uwagę projekt w czystym Kotlinie, co należy zrobić, jeśli istnieje potrzeba małego,...
Poniższy kod powoduje błąd kompilacji z komunikatem „nieoczekiwane zakończenie”: x := go doSomething(arg) func doSomething(arg int) int{ ... return my_int_value } Wiem, że mogę pobrać wartość zwracaną, jeśli wywołam funkcję normalnie, bez użycia goroutine. Lub mogę użyć kanałów itp. Moje...
Mam klasę, która pobiera obiekty z a BlockingQueuei przetwarza je, wywołując take()w ciągłej pętli. W pewnym momencie wiem, że do kolejki nie zostaną dodane żadne obiekty. Jak przerwać take()metodę, aby przestała blokować? Oto klasa przetwarzająca obiekty: public class MyObjHandler implements...
W jaki sposób można wykorzystać przetwarzanie wieloprocesowe, aby rozwiązać kłopotliwie równoległe problemy ? Żenująco równoległe problemy zazwyczaj składają się z trzech podstawowych części: Odczytaj dane wejściowe (z pliku, bazy danych, połączenia TCP itp.). Uruchom obliczenia na danych...
Czy istnieje sposób ochrony przed równoczesnymi modyfikacjami tego samego wpisu w bazie danych przez dwóch lub więcej użytkowników? Dopuszczalne byłoby wyświetlenie komunikatu o błędzie użytkownikowi wykonującego drugą operację zatwierdzenia / zapisania, ale dane nie powinny być po cichu...
Jak wyczyścić ConcurrentBag? nie ma żadnej metody takiej jak Clearlub RemoveAll...
Czy zwróci fałsz tylko wtedy, gdy słownik nie zawiera wartości dla danego klucza, czy też zwróci fałsz z powodu warunków wyścigu wątków, tak jak inny wątek coś dodaje / aktualizuje? Pytanie w kodzie: ConcurrentDictionary<int, string> cd = new ConcurrentDictionary<int,...
Model programowania oparty na zdarzeniach node.js sprawia, że koordynacja przepływu programu jest nieco trudna. Proste sekwencyjne wykonywanie zostaje zamienione w zagnieżdżone wywołania zwrotne, co jest dość łatwe (choć zapisywanie jest nieco zawiłe). Ale co z równoległym wykonaniem?...
Próbując zrozumieć, w jaki sposób SubmissionPublisher( kod źródłowy w Java SE 10, OpenJDK | docs ), nowa klasa dodana do Java SE w wersji 9, została zaimplementowana, natknąłem się na kilka wywołań API, VarHandlektórych wcześniej nie byłem świadomy: fullFence, acquireFence, releaseFence,...
Potrzebuję usługi, która uruchomi kilka zadań jednocześnie i w odstępie 1 sekundy przez 1 minutę. Jeśli jedno z zadań się nie powiedzie, chcę zatrzymać usługę i każde zadanie, które się z nią uruchomiło, z jakimś wskaźnikiem, że coś poszło nie tak, inaczej jeśli po minucie wszystko pójdzie dobrze,...
Czy karliny Kotlin dają jakieś gwarancje „zdarzy się przed”? Na przykład, czy w tym przypadku istnieje gwarancja „dzieje się przed” między zapisem mutableVara późniejszym odczytem (potencjalnie) innego wątku: suspend fun doSomething() { var mutableVar = 0 withContext(Dispatchers.IO) {...
push_back , zaczynają , koniec opisane są jako równoczesne sejf w https://docs.microsoft.com/en-us/cpp/parallel/concrt/reference/concurrent-vector-class?view=vs-2019#push_back Jednak poniższy kod jest twierdzący. Prawdopodobnie dlatego, że element został dodany, ale jeszcze nie...
Wysłuchałem i przeczytałem kilka artykułów, rozmów i pytań o przepełnienie stosu std::atomici chciałbym mieć pewność, że dobrze to zrozumiałem. Ponieważ nadal jestem trochę mylony z linią pamięci podręcznej zapisuje widoczność z powodu możliwych opóźnień w protokołach koherencji pamięci podręcznej...
Wzorzec, z którym się zetknąłem już wiele razy, jest taki, w którym należy sprawdzić listę wartości, mapując na niej jakiś test i sprawdzając, czy którykolwiek lub wszystkie elementy przeszły. Typowym rozwiązaniem jest po prostu użycie wygodnych wbudowanych alli any. Problem polega na tym, że...