Ich benutze RabbitMQ in Python, um mehrere Warteschlangen zwischen einem Produzenten und mehreren Konsumenten zu verwalten. Im Beispiel auf der RabbitMQ-Website ( Routing-Modell ) sind die Konsumenten blockiert. Dies bedeutet, dass sie bei start_consuming () anhalten und die Callback-Funktion jedes Mal ausführen, wenn sich eine neue "Aufgabe" in der Warteschlange befindet.
Meine Frage ist: Wie kann ich meinen Consumer so implementieren, dass er immer noch auf Aufgaben wartet (so wird die Callback-Funktion jedes Mal aufgerufen, wenn neue Dinge in der Warteschlange sind), aber gleichzeitig kann er andere ausführen Arbeit / Code.
Danke
für Empfänger
%Vor%und
%Vor%wenn Sie brauchen) oder in threading
%Vor%Tags und Links python queue asynchronous rabbitmq parallel-processing