Ich möchte ungefähr Folgendes tun: Anfänglicher Thread: Schreiben Sie einige Werte in globale Variablen (sie werden nie wieder geschrieben). Dies können mäßig große Daten sein (Arrays, Strings usw.). Kann nicht einfach gemacht werden std::atomic<>. andere Threads erzeugen Andere Themen: Lesen...
Ich versuche, Multithreading in c ++ zu verstehen, aber ich stecke in diesem Problem fest: Wenn ich Threads in einer for-Schleife starte, drucken sie falsche Werte. Dies ist der Code: #include <iostream> #include <list> #include <thread> void print_id(int id){ printf("Hello from...
Ich arbeite an einer Java-Anwendung zur Lösung einer Klasse numerischer Optimierungsprobleme - genauer gesagt bei großen linearen Programmierproblemen. Ein einzelnes Problem kann in kleinere Teilprobleme aufgeteilt werden, die parallel gelöst werden können. Da es mehr Unterprobleme als CPU-Kerne...
Das Code-Snippet finden Sie unten: 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;...
Ich versuche die Multithread-Funktion von Julia 1.3mit der folgenden Hardware: Model Name: MacBook Pro Processor Name: Intel Core i7 Processor Speed: 2.8 GHz Number of Processors: 1 Total Number of Cores: 4 L2 Cache (per Core): 256 KB L3 Cache: 6 MB Hyper-Threading Technology: Enabled Memory: 16 GB...
Ich habe die offizielle Dokumentation von React-Native und einige andere Medienquellen und Blogs durchgesehen und festgestellt, dass UI-Thread und JavaScript-Thread in React-Native enthalten sind. Javascript-Thread ist der Thread, in dem die Logik Javascript-Code ausführt, API-Aufrufe ausgeführt,...
In der Dokumentation von std::memory_ordercppreference.com finden Sie ein Beispiel für eine entspannte Bestellung: Entspannte Bestellung Mit Tags versehene atomare Operationen memory_order_relaxedsind keine Synchronisationsoperationen. Sie legen keine Reihenfolge bei gleichzeitigen...
Ich stoße auf ein Problem, bei dem, wenn ich versuche, die Größe des Kernpools eines ThreadPoolExecutorPools nach dem Erstellen des Pools auf eine andere Anzahl zu ändern , einige Aufgaben zeitweise mit einem abgelehnt werden RejectedExecutionException, obwohl ich nie mehr als die queueSize +...
Nach dem Blick auf ein Bündel von anderen Fragen und ihre Antworten , habe ich den Eindruck , dass es auf das, was die „flüchtig“ Schlüsselwort in C genau bedeutet keine weitgehende Übereinstimmung ist. Selbst der Standard selbst scheint nicht klar genug zu sein, damit sich alle einig sind was er...
Ich benötige einen Dienst, der einige Aufgaben gleichzeitig und im Abstand von 1 Sekunde für 1 Minute ausführt. Wenn eine der Aufgaben fehlschlägt, möchte ich den Dienst und jede damit ausgeführte Aufgabe mit einer Art Indikator beenden, dass etwas schief gelaufen ist. Wenn andernfalls nach einer...
Ich verwende std::for_eachmit std::execution::par, um komplexe Berechnungen für große Eingaben durchzuführen, die als Vektor von Strukturen dargestellt werden. Die Berechnung erfordert keine Verzögerungen in Bezug auf Hardware (z. B. Netzwerk- oder Festplatten-E / A), sondern ist "nur CPU"...
Ich habe eine Liste, aus der verschiedene Threads Elemente abrufen sollen. Um zu vermeiden, dass der Mutex die Liste schützt, wenn er leer ist, überprüfe ich dies empty()vor dem Sperren. Es ist in Ordnung, wenn der Anruf zu list::empty()100% nicht richtig ist. Ich möchte nur vermeiden, dass...
Ich benutze Flutter Desktop für Linux. Ich rufe eine Methode namens aufMarkTextureFrameAvailable , die eine Textur markieren soll, die von der Engine erneut gerendert werden soll. Da ich einen Videoplayer programmiere, muss ich über MarkTextureFrameAvailableden Thread des Players aufrufen . Das...
Kann mir jemand sagen, ob std :: atomic :: is_lock_free () nicht so statisch wie constexpr ist? Es macht für mich keinen Sinn, es nicht statisch und / oder nicht kontextuell zu
Der Ausdruck "passiert stark vor" wird im C ++ - Entwurfsstandard mehrmals verwendet. Zum Beispiel: Kündigung [basic.start.term] / 5 Wenn der Abschluss der Initialisierung eines Objekts mit statischer Speicherdauer stark vor einem Aufruf von std :: atexit erfolgt (siehe [support.start.term]), wird...
Ich versuche, den folgenden Code mithilfe von Multithreading auf Auftragsebene zu verarbeiten. List<String> orders = Arrays.asList("order1", "order2", "order3", "order4", "order1"); Aktuelle sequentielle Ausführung: orders.stream().forEach(order -> { rules.forEach(rule -> {...
Ich starte einen Spawn-Child-Prozess folgendermaßen: let process = spawn(apiPath, { detached: true }) process.unref() process.stdout.on('data', data => { /* do something */ }) Wenn ich den Prozess starte, muss ich ihn angehängt halten, da ich seine Ausgabe lesen möchte. Aber kurz bevor ich...
Der Zustand docs JavaFX , dass ein WebViewbereit ist , wenn Worker.State.SUCCEEDEDerreicht wird , aber wenn Sie eine Weile warten (dh Animation, Transition, PauseTransition, etc.), wird eine leere Seite gerendert. Dies deutet darauf hin, dass im WebView ein Ereignis auftritt, das es für eine...
Folgendes meine ich: public Task<SomeObject> GetSomeObjectByTokenAsync(int id) { string token = repository.GetTokenById(id); if (string.IsNullOrEmpty(token)) { return Task.FromResult(new SomeObject() { IsAuthorized = false }); } else { return
Nachfolgend finden Sie eine Implementierung einer ineinandergreifenden Methode, die auf basiert Interlocked.CompareExchange. Ist es ratsam, dass dieser Code SpinWaitvor dem Wiederholen einen Spin verwendet? public static bool AddIfLessThan(ref int location, int value, int comparison) { int...