Suchergebnisse für Anfrage "concurrency"
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 ...
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 ...
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 ...
Was bedeutet die intrinsische Sperre für eine Java-Klasse?
Um die Probleme und Lösungen für Parallelität in Java richtig zu verstehen, habe ich das offizielle Java-Tutorial durchgearbeitet. Auf einer der Seiten haben sie @ definieIntrinsic Locks und Synchronisation ...
Ist dies ein idiomatischer Worker-Thread-Pool in Go?
Ich versuche einen einfachen Arbeiterpool mit Goroutinen zu schreiben. Ist der Code, den ich geschrieben habe, idiomatisch? Wenn nicht, was sollte sich dann ändern?Ich möchte in der Lage sein, die maximale Anzahl von Worker-Threads auf 5 ...
AWS Lambda und Java-Parallelität
Es ist bekannt, dass AWS Lambdakan früh erstellte Objekte von Handlern wiederverwenden, und das macht es wirklich (sieheFA [https://aws.amazon.com/lambda/faqs/]): F: Wird AWS Lambda Funktionsinstanzen wiederverwenden? Um die Leistung zu ...
Wie man mehrere in einer Spalte einer RDD gespeicherte json-Tabellen so effizient wie möglich auf eine einzelne RDD-Tabelle reduziert
Funktioniert der gleichzeitige Zugriff auf das Anhängen von Zeilen mithilfe von union in einem Datenframe mithilfe des folgenden Codes ordnungsgemäß? Derzeit wird der Typ error @ angezeig from pyspark.sql.types import * schema = StructType([ ...
Wie Sie sicherstellen, dass jedes Objekt mit Firebase FlashLight in einer kostenlosen ElasticSearch Bonsai-Instanz indiziert wird
Danke an das Tutorial der FlashLighthttps: //github.com/firebase/flashligh [https://github.com/firebase/flashlight], das ist irgendwie einfach mit Firebase Volltextsuche zu machen. Wenn Sie jedoch die kostenlose ES-Instanz behalten, ist sie im ...
Begrenzung gleichzeitiger Anforderungen mit Rx und SelectMany
Ich habe eine Liste mit URLs von Seiten, die ich gleichzeitig mit @ herunterladen möchtHttpClient. Die Liste der URLs kann groß sein (100 oder mehr!) Ich habe derzeit diesen Code: var urls = new List<string> { @"http:\\www.amazon.com", ...