wamd icon indicating copy to clipboard operation
wamd copied to clipboard

Is there a guide for the library to run parallel?

Open krypton-byte opened this issue 3 years ago • 4 comments

krypton-byte avatar Dec 16 '21 03:12 krypton-byte

could you explain in more detail?

serenity-77 avatar Dec 16 '21 11:12 serenity-77

Let's say I have five messages that process messages simultaneously without having to wait for the previous one to be processed

krypton-byte avatar Dec 16 '21 13:12 krypton-byte

Twisted is an event driven networking engine and provide a deferred that hold an eventual result much like Promise or Future.

connection.relayMessage return a deferred that fired with the message instance you send

so you can send more than one message at once and wait for their results like so:

from twisted.internet import defer
deferredLIst = []
for mesage in messages:
    d = connection.relayMessage(message)
    deferredList.append(d)

deferred = defer.gatherResults(deferredList)

def onResults(results):
    print(results)

deferred.addCallback(onResults)

serenity-77 avatar Dec 16 '21 15:12 serenity-77

How to send message with scheduler, eg celery or redis queue

syifarahmat avatar Mar 30 '22 10:03 syifarahmat