Is client multithreaded?

[gaurav2001trader]

condition = true
def onMessage():
    global conditon
    if condition: 
       # condition = False ---> This works
       # do something 
       condition = False

By my logic onMessage should only run once. However onMessage gets executed a couple of times before stopping when triggered multiple times in a very short period of time. If I set condition = False just after I checked the boolean it works fine. Is this because of multithreading? I am using socketio.Client

[miguelgrinberg]

Yes, the client is multithreaded.

[gaurav2001trader]

https://github.com/symphonyfintech/xts-pythonclient-api-sdk/blob/main/MarketDataSocketClient.py
https://github.com/symphonyfintech/xts-pythonclient-api-sdk/blob/main/MarketdataSocketExample.py

I was writing the previous logic inside on_message1502_json_full. Now on_message1502_json_full is triggered continuously and race condition is created. What I want is the code inside on_message1502_json_full is only executed by one thread at a time

[miguelgrinberg]

My reply above stands. Use a Lock.

[gaurav2001trader]

Ok I understand how to use lock with threads but how do I access the thread while using socketIO library. One way I can think is spawn threads inside the on_message1502_json_full and target them to some other function where I can lock the threads.

[miguelgrinberg]

You don't need to access the thread. Following your example:

condition = true
myLock = Lock()

def onMessage():
    global condition
    with myLock:
        if condition: 
           # do something 
           condition = False

[gaurav2001trader]

Ok thankyou for your time