Не удается заблокировать поток в сокете, используя Multiprocess

Question

Я прошел по ссылке: multiprocessing.Pool - PicklingError: Невозможно засечь : поиск атрибута thread.lock не выполнен
Тем не менее я не получил решение для этого.
Вот что я попробовал:
Сервер

import multiprocessing
import socket
from iqoptionapi.stable_api import IQ_Option
import time

def handle(client_socket,address,I_want_money):
    print(address)
    client_socket.sendall("Happy".encode())
    client_socket.close() 
    return
class Server(object):
    def __init__(self, hostname, port):
        # import logging
        # self.logger = logging.getLogger("server")
        self.hostname = hostname
        self.port = port
        self.I_want_money=IQ_Option("email","password")
        self.I_want_money.suspend = 0.1
        print("I am ON.........")


    def start(self):
        # self.logger.debug("listening")
        self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.socket.bind((self.hostname, self.port))
        self.socket.listen(1)

        while True:
            conn, address = self.socket.accept()
            # self.logger.debug("Got connection")
            process = multiprocessing.Process(target=handle, args=(conn, address,self.I_want_money,))
            process.daemon = True
            process.start()
            # self.logger.debug("Started process %r", process)

if __name__ == "__main__":
    # import logging
    # logging.basicConfig(level=logging.DEBUG)

    server = Server("0.0.0.0", 9000)
    try:
        # logging.info("Listening")
        server.start()
    except Exception as e:
        print(e, "\n I had experienced at initialization")
        # logging.exception("Unexpected exception")
    finally:
        # logging.info("Shutting down")
        for process in multiprocessing.active_children():
            # logging.info("Shutting down process %r", process)
            process.terminate()
            process.join()
    # logging.info("All done")

Это клиент:

import socket
if __name__ == "__main__":
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.connect(("localhost", 9000))
    for i in range(100):        
        data = "some data"
        sock.sendall(data.encode())
        result = sock.recv(1024)
        print(result)
    sock.close()

И, наконец, полученная ошибка:

login...
I am ON.........
Can't pickle <class '_thread.lock'>: attribute lookup lock on _thread failed
 I had experienced at initialization
Press any key to continue . . . Traceback (most recent call last):
  File "<string>", line 1, in <module>
  File "C:\Python35\lib\multiprocessing\spawn.py", line 100, in spawn_main
    new_handle = steal_handle(parent_pid, pipe_handle)
  File "C:\Python35\lib\multiprocessing\reduction.py", line 81, in steal_handle
    _winapi.PROCESS_DUP_HANDLE, False, source_pid)
OSError: [WinError 87] The parameter is incorrect

Пожалуйста. дайте мне знать решение для такой ситуации. Я использую Python 3.5.0

Answer 1

Вероятно, объект API IQOption владеет потоком, который нельзя передать подпроцессам.Вместо этого используйте потоки для параллелизма ...

Вот примерно эквивалентная (непроверенная) версия кода вашего сервера с использованием встроенного модуля socketserver с использованием потоков (с ThreadingMixIn) для распараллеливания каждого клиентского соединения.

from iqoptionapi.stable_api import IQ_Option
import socketserver

I_want_money = IQ_Option("email", "password")
I_want_money.suspend = 0.1


class RequestHandler(socketserver.BaseRequestHandler):
    def handle(self):
        print(self.client_address)
        request.sendall("Happy".encode())
        request.close()


server = socketserver.ThreadingTCPServer(("0.0.0.0", 9000), RequestHandler)
server.serve_forever()