websocket-clientでの、on_message関数を並列処理する方法

Question

websocket-clientパッケージを用いて、随時送られてくるwebsocketデータを受信するプログラムを作成しているのですが、
on_message関数内の処理に時間がかかるため、処理中に次のデータが送られてきてしまう場合があります。

この場合、現在のon_message関数の処理が完了するまで次のon_message関数の実行を待機する挙動となっている認識です。

これを並列処理（on_message関数の完了を待たずに次のon_message関数を実行）させるにはどうすればよいでしょうか。

以下のようなコードを想定しています。

class Test1():
    def __init__(self,host_adr):
        print("### start ###")
　　　　self.ws = websocket.WebSocketApp(host_addr,
                                         on_message=lambda ws, msg: self.on_message(ws, msg),
                                         on_error=lambda ws, msg: self.on_error(ws, msg),
                                         on_close=lambda ws: self.on_close(ws))
        self.ws.on_open = lambda ws: self.on_open(ws)
        websocketThread = threading.Thread(target=self.run_forever, args=())
        websocketThread.start()
  
    def on_message(self, ws, message):
        （この部分の処理が時間がかかってしまうので、並列処理させたいです）
        
    def on_error(self, ws, error):
        print(error)

    def on_close(self, ws):
        print("### closed ###")

    def on_open(self, ws):
        thread.start_new_thread(self.run, ())

    def run(self, *args):
        time.sleep(0.1)
        input_data = (Websocket開始時に送るデータ)
        self.ws.send(input_data)

    def run_forever(self):
        while True:
            try:
                self.ws.run_forever()
            except Exception as e:
                print(e)
            time.sleep(3)

if __name__ == '__main__':
    HOST_ADDR = (WebSocket送信元)
    ws_client = Test1(HOST_ADDR)

Answer 1

Threadを使う代わりに、multiprocessingを使ってみてはいかがですか。

ProcessPoolExecutorを使う例がWebsockets and multiprocessingの回答に書かれています。