Mam pojedynczy duży plik tekstowy, w którym chcę przetworzyć każdą linię (wykonać pewne operacje) i przechowywać je w bazie danych. Ponieważ pojedynczy prosty program trwa zbyt długo, chcę, aby był wykonywany za pomocą wielu procesów lub wątków. Każdy wątek / proces powinien odczytywać RÓŻNE...
Mam dwa wątki, jeden aktualizujący int, a drugi czytający. Jest to wartość statystyczna, w przypadku której kolejność odczytów i zapisów nie ma znaczenia. Moje pytanie brzmi, czy mimo wszystko muszę zsynchronizować dostęp do tej wartości wielobajtowej? Innymi słowy, część zapisu może zostać...
Mam kilka właściwości, na których mam zamiar używać blokad odczytu / zapisu. Mogę je zaimplementować za pomocą klauzuli try finallylub usingklauzuli. W przypadku try finallyzdobycia blokady przed tryi zwolnienia w finally. W usingklauzuli utworzyłbym klasę, która uzyskuje blokadę w swoim...
Jak zaimplementowano ThreadLocal? Czy jest zaimplementowany w Javie (przy użyciu pewnej współbieżnej mapy z ThreadID do obiektu), czy może używa jakiegoś haka JVM, aby zrobić to bardziej wydajnie?
Niedawno zacząłem programować w WPF i napotkałem następujący problem. Nie rozumiem, jak używać tej Dispatcher.Invoke()metody. Mam doświadczenie w tworzeniu wątków i stworzyłem kilka prostych programów Windows Forms, w których właśnie użyłem Control.CheckForIllegalCrossThreadCalls =...
W programie ArrayBlockingQueuewszystkie metody, które wymagają blokady, kopiują ją do finalzmiennej lokalnej przed wywołaniem lock(). public boolean offer(E e) { if (e == null) throw new NullPointerException(); final ReentrantLock lock = this.lock; lock.lock(); try { if (count ==...
Używam visualVM podłączam wielowątkową aplikację Java, wątek ma status 4, a mianowicie działa, śpi, czekaj, monitor. Co oznacza ten stan monitorowania? Jaka jest różnica między czekaniem a monitorem?
Muszę przeprowadzić serię operacji pobierania i zapisywania bazy danych w mojej aplikacji. Używam NSOperationi NSOperationQueuedo tego samego. To jest scenariusz aplikacji: Pobierz wszystkie kody pocztowe z miejsca. Dla każdego kodu pocztowego pobierz wszystkie domy. Dla każdego domu należy...
Uruchamiam aplikację C # i podczas wykonywania otrzymuję następujący błąd: Środowisko CLR nie mogło przejść z kontekstu COM 0x20e480 do kontekstu COM 0x20e5f0 przez 60 sekund. Wątek będący właścicielem kontekstu / apartamentu docelowego najprawdopodobniej albo wykonuje oczekiwanie bez...
Robię bardzo głupi benchmark na ReaderWriterLock z tym kodem, w którym czytanie odbywa się 4x częściej niż pisanie: class Program { static void Main() { ISynchro[] test = { new Locked(), new RWLocked() }; Stopwatch sw = new Stopwatch(); foreach ( var isynchro in test ) { sw.Reset();...
Jak duża jest pula wątków Scali dla kontraktów terminowych? Moja aplikacja Scala zarabia wiele milionów future {}i zastanawiam się, czy jest coś, co mogę zrobić, aby je zoptymalizować, konfigurując pulę wątków. Dziękuję Ci.
Jaka jest różnica między poniższymi ThreadPool.QueueUserWorkItem vs Task.Factory.StartNew Jeśli powyższy kod jest wywoływany 500 razy dla jakiegoś długotrwałego zadania, czy oznacza to, że wszystkie wątki puli wątków zostaną zajęte? A może TPL (druga opcja) będzie wystarczająco...
Dlaczego Threadklasa została zaimplementowana jako zwykła klasa, a nie klasa abstrakcyjna z run()metodą abstrakcyjną. Czy może to spowodować jakieś problemy? A może ma to jakiś sens? Ponadto Thread.start()metoda ma być bardzo specyficzną metodą, której funkcjonalności nie może zaimplementować...
Napisałem proste programy wielowątkowe w następujący sposób: static bool finished = false; int func() { size_t i = 0; while (!finished) ++i; return i; } int main() { auto result=std::async(std::launch::async, func); std::this_thread::sleep_for(std::chrono::seconds(1)); finished=true;...
Jeśli mam program działający z wątkami i wywołujący fork()system uniksowy, czy wątki są kopiowane? Wiem, że pamięć wirtualna dla bieżącego procesu jest kopiowana 1: 1 do nowego spawnowanego procesu. Wiem, że wątki mają swój własny stos w wirtualnej pamięci procesu. Dlatego przynajmniej stos wątków...
Pytanie Jak utworzyć właściwy moduł ładujący w tle w Javie 8? Warunki: dane powinny być ładowane w tle po załadowaniu dane powinny zostać wyświetlone podczas ładowania danych nie należy przyjmować dalszych żądań jeśli podczas ładowania danych pojawiały się żądania, po upływie określonego czasu...
Chcę z grubsza to zrobić: Początkowy wątek: napisz niektóre wartości do globalnych zmiennych (nigdy więcej nie zostaną zapisane) Mogą to być umiarkowanie duże dane (tablice, ciągi itp.). Nie można tego po prostu zrobić std::atomic<>. spawnuj inne wątki Inne wątki: przeczytaj stan...
Próbuję zrozumieć wielowątkowość w c ++, ale utknąłem w tym problemie: jeśli uruchomię wątki w pętli for, wypiszą one nieprawidłowe wartości. To jest kod: #include <iostream> #include <list> #include <thread> void print_id(int id){ printf("Hello from thread %d\n", id); } int...
Pracuję nad aplikacją Java do rozwiązywania problemów z optymalizacją numeryczną - a dokładniej - problemów programowania liniowego na dużą skalę. Pojedynczy problem można podzielić na mniejsze podproblemy, które można rozwiązać równolegle. Ponieważ jest więcej podproblemów niż rdzeni procesora,...
Fragment kodu znajduje się poniżej: class tFunc{ int x; public: tFunc(){ cout<<"Constructed : "<<this<<endl; x = 1; } ~tFunc(){ cout<<"Destroyed : "<<this<<endl; } void operator()(){ x += 10; cout<<"Thread running at : "<<x<<endl;...