Ich habe Javas ConcurrentMap für eine Map verwendet, die von mehreren Threads verwendet werden kann. PutIfAbsent ist eine großartige Methode und viel einfacher zu lesen / schreiben als die Verwendung von Standardkartenoperationen. Ich habe einen Code, der so aussieht: ConcurrentMap<String,...
Ich lese ein Buch, das das SyncRoot-Muster beschreibt. Es zeigt void doThis() { lock(this){ ... } } void doThat() { lock(this){ ... } } und vergleicht mit dem SyncRoot-Muster: object syncRoot = new object(); void doThis() { lock(syncRoot ){ ... } } void doThat() { lock(syncRoot){ ... } }...
Gemäß: http://www.ibm.com/developerworks/library/j-jtp03304/ Wenn unter dem neuen Speichermodell Thread A in eine flüchtige Variable V schreibt und Thread B aus V liest, ist garantiert, dass alle Variablenwerte, die zum Zeitpunkt des Schreibens von V für A sichtbar waren, jetzt für B sichtbar sind...
Ich habe ein seltsames Verhalten mit meiner Test-App. Ich habe ungefähr 50 gleichzeitige GET-Anforderungen, die ich an denselben Server sende. Der Server ist ein eingebetteter Server auf einer kleinen Hardware mit sehr begrenzten Ressourcen. Um die Leistung für jede einzelne Anforderung zu...
Beim Versuch zu verstehen, wie SubmissionPublisher( Quellcode in Java SE 10, OpenJDK | docs ), eine neue Klasse, die in Version 9 zu Java SE hinzugefügt wurde, implementiert wurde, stieß ich auf einige API-Aufrufe, die VarHandlemir bisher nicht bekannt waren: fullFence, acquireFence, releaseFence,...
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...
Bieten Kotlin-Coroutinen Garantien für "Vorheriges"? mutableVarGibt es in diesem Fall beispielsweise eine "Vorher-passiert" -Garantie zwischen dem Schreiben in und dem anschließenden Lesen eines (möglicherweise) anderen Threads: suspend fun doSomething() { var mutableVar = 0...
push_back , begin , end werden in https://docs.microsoft.com/en-us/cpp/parallel/concrt/reference/concurrent-vector-class?view=vs-2019#push_back als gleichzeitig sicher beschrieben Der folgende Code bestätigt jedoch. Wahrscheinlich, weil das Element hinzugefügt, aber noch nicht initialisiert wurde....
Ich habe mehrere Artikel, Vorträge und Fragen zum Stackoverflow angehört und gelesen std::atomicund möchte sichergehen, dass ich sie gut verstanden habe. Weil ich immer noch ein bisschen verwirrt bin mit der Sichtbarkeit von Cache-Zeilen-Schreibvorgängen aufgrund möglicher Verzögerungen bei...
Ein Muster, auf das ich jetzt schon mehrmals gestoßen bin, ist eines, bei dem eine Liste von Werten überprüft werden muss, indem ein Test darüber abgebildet wird und geprüft wird, ob einige oder alle Elemente bestanden wurden. Die typische Lösung besteht darin, nur die praktischen Einbauten allund...
Angenommen, ich habe ein Feld, auf das gleichzeitig zugegriffen wird und das viele Male gelesen und selten beschrieben wird. public Object myRef = new Object(); Angenommen, ein Thread T1 setzt myRef einmal pro Minute auf einen anderen Wert, während N andere Threads myRef milliardenfach...
Ich möchte ein Programm schreiben, dessen Hauptthread einen neuen Thread zur Berechnung gibt und darauf wartet, dass er eine Zeit lang beendet wird. Wenn der untergeordnete Thread nicht in einer bestimmten Zeit beendet wird, wird eine Zeitüberschreitung festgestellt und beendet. Ich habe den...