ThreadedWebsocketManager instance calls start_kline_futures_socket() from another thread and does not print kline data

[tonytao0]

test.py:

from binance import ThreadedWebsocketManager

import time
import threading

twm: ThreadedWebsocketManager
symbol = "BTCUSDT"

def handle_socket_message(msg):
    print('handle_socket_message',msg)

def test_threaded_socket_manager():
    global twm
    print('test_threaded_socket_manager run')
    print('id:',id(twm))
    print('type:',type(twm))

    sock_id = twm.start_kline_futures_socket(callback=handle_socket_message, symbol=symbol)
    time.sleep(10)
    twm.stop_socket(sock_id)

    print('test_threaded_socket_manager stop')

if __name__ == '__main__':
    twm = ThreadedWebsocketManager(api_key="", api_secret="", testnet=False)
    twm.start()
    print('id:',id(twm))
    print('type:',type(twm))

    t = threading.Thread(target=test_threaded_socket_manager)
    t.start()
    t.join()
 
    twm.stop()
    print('quit')

run and print:

  id: 139899228454864
  type: <class 'binance.ws.streams.ThreadedWebsocketManager'>
  test_threaded_socket_manager run
  id: 139899228454864
  type: <class 'binance.ws.streams.ThreadedWebsocketManager'>
  test_threaded_socket_manager stop
  quit

[tonytao0]

ThreadedWebsocketManager instantiated and called start_kline_futures_socket on the same thread worked fine

However, different threads cannot receive kline data when one thread is instantiated while another thread calls start_kline_futures_socket function

[pcriadoperez]

Hi @tonytao0 ,

Thanks for reporting.
So each thread should create its own TWM instance, TWM instance should be created and used in the same thread and not shared across threads as each TWM manages its own async event loop. The processing and callback you can put in a different thread.

Can I ask, why are you trying to separate into different threads?