Suchergebnisse für Anfrage "concurrency"
Individuelle Zeitüberschreitungen für gleichzeitige.futures
Ich sehe zwei Möglichkeiten, um Zeitüberschreitungen in @ anzugebe concurrent.futures [https://docs.python.org/3/library/concurrent.futures.html]. as_completed()wait()Beide Methoden behandeln N laufende Futures. Ich möchte für jede Zukunft ein ...
Wrapping Rate Limiting API-Aufruf
Ich habe Zugriff auf einen API-Aufruf, derkzeptiert eine maximale Anrufrate pro Sekun. Wenn die Rate überschritten wird, wird einException wird geworfen. Ich möchte diesen Anruf in eine Abstraktion einbinden, die das Notwendige tut, um die ...
Wie rufen wir eine normale Funktion auf, bei der eine Coroutine erwartet wird?
Betrachten Sie eine Coroutine, die eine andere Coroutine aufruft: async def foo(bar): result = await bar() return resultDies funktioniert gut, wennbar ist eine Coroutine. Was muss ich tun (d. H. Womit muss ich den Anruf an @ beendenbar) damit ...
Concurrent Sammlungen in C #
Ich suche nach einer Möglichkeit, eine gleichzeitige Auflistung in C # oder zumindest eine Auflistung zu erhalten, die einen gleichzeitigen Enumerator unterstützt. Im Moment erhalte ich eine InvalidOperationException, wenn sich die Sammlung, ...
Gewährleistet Standard C ++ 11, dass memory_order_seq_cst die Neuanordnung von Nicht-Atomen um ein Atom in StoreLoad verhindert?
Garantiert C ++ 11, dassmemory_order_seq_cst verhindert, dass StoreLoad eine atomare Operation für nicht-atomare Speicherzugriffe neu anordnet? ie bekannt, gibt es 6std::memory_orders in C ++ 11 und seine Angabenie regelmäßig, nicht atom ...
Schreib- / Lesesperre mit nur einer zugrunde liegenden Sperre?
Ich habe eine Lese- / Schreibsperre mit Pythons Parallelitätsprimitiven geschrieben (glaube ich!). Jede Implementierung, die ich auf SO oder anderswo gelesen habe, scheint zwei Sperren zu verwenden - eine für Lesevorgänge und eine für ...
Anzahl der von Go Runtime verwendeten Threads
Wie viele Threads kann die Go-Laufzeitumgebung (Scheduler, Garbage Collector usw.) verwenden? Zum Beispiel, wennGOMAXPROCS ist10, wie viele dieser Kernel-Threads würden von der Laufzeit verwendet? BearbeitenIch habe gelesendas ...
Bietet ConcurrentMap.remove () eine Flanke vor dem Eintreten, bevor get () null zurückgibt?
Sind Aktionen in einem Thread vor dem Aufrufen vonConcurrentMap.remove() garantiert zu happen-before Aktionen nach dem Entfernen aus einem ...
Asynchrones Durchlaufen der Antwort einer Anforderung mit Thin und Sinatra
Wenn Ihre Antwort in Sinatra ein 'eachable'-Objekt zurückgibt, wird die Ereignisschleife von Sinatra Ihr Ergebnis' einzeln 'und die Ergebnisse als HTTP-Antwort in Streaming-Form ausgeben. Wenn jedoch gleichzeitige Anforderungen an Sinatra ...
Speicherbarrieren und Codierungsstil über eine Java VM
Angenommen, ich habe ein statisches komplexes Objekt, das regelmäßig von einem Pool von Threads aktualisiert wird und mehr oder weniger kontinuierlich in einem Thread mit langer Laufzeit gelesen wird. Das Objekt selbst ist immer unveränderlich ...