Как использовать многопроцессорную работу с веб-сокетами? - PullRequest
0 голосов
/ 27 сентября 2018

Ниже приведен пример websocket, который использует потоки для поддержания соединения через веб-сокет.

import websocket
import threading
from time import sleep

def on_message(ws, message):
    print message

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

if __name__ == "__main__":
    websocket.enableTrace(True)
    ws = websocket.WebSocketApp("ws://echo.websocket.org/", on_message = on_message, on_close = on_close)
    wst = threading.Thread(target=ws.run_forever)
    wst.daemon = True
    wst.start()

    conn_timeout = 5
    while not ws.sock.connected and conn_timeout:
        sleep(1)
        conn_timeout -= 1

    msg_counter = 0
    while ws.sock.connected:
        ws.send('Hello world %d'%msg_counter)
        sleep(1)
        msg_counter += 1

Мне интересно, как я могу изменить этот код, чтобы вместо него использовать Process?Потоки не параллельны из-за GIL, и я хочу ускорить этот код.Я сам пытался преобразовать этот код, однако моя главная проблема заключается в том, как передать данные из процесса сокета в основной процесс.

Кто-нибудь знает, как преобразовать этот код?У меня трудности.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...